flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jingsong Li <jingsongl...@gmail.com>
Subject Re: Read data from Oracle using Flink SQL API
Date Thu, 06 Feb 2020 09:53:35 GMT
Hi Bowen,

JIRA exists: https://issues.apache.org/jira/browse/FLINK-14078

Best,
Jingsong Lee

On Thu, Feb 6, 2020 at 12:57 PM Bowen Li <bowenli86@gmail.com> wrote:

> Hi Flavio,
>
> +1 for adding Oracle (potentially more dbms like SqlServer, etc) to
> flink-jdbc. Would you mind open a parent ticket and some subtasks, each one
> for one to-be-added dbms you've thought of?
>
>
> On Sun, Feb 2, 2020 at 10:11 PM Jingsong Li <jingsonglee0@gmail.com>
> wrote:
>
>> Yes, And I think we should add OracleDialect,SqlServerDialect,DB2Dialect
>> support too.
>>
>> Best,
>> Jingsong Lee
>>
>> On Sun, Feb 2, 2020 at 5:53 PM Flavio Pompermaier <pompermaier@okkam.it>
>> wrote:
>>
>>> Ok thanks for this info! Maybe this could be added to the
>>> documentation..what do you think?
>>>
>>> Il Dom 2 Feb 2020, 08:37 Jingsong Li <jingsonglee0@gmail.com> ha
>>> scritto:
>>>
>>>> Hi Flavio,
>>>>
>>>> You can use `JDBCTableSource`, and register it from
>>>>  TableEnvionment.registerTableSource, you need provide
>>>>  a OracleDialect, maybe just implement `canHandle` and
>>>>  `defaultDriverName` is OK.
>>>>
>>>> Best,
>>>> Jingsong Lee
>>>>
>>>> On Sun, Feb 2, 2020 at 2:42 PM Jark Wu <imjark@gmail.com> wrote:
>>>>
>>>>> Hi Flavio,
>>>>>
>>>>> If you want to adjust the writing statement for Oracle, you can
>>>>> implement the JDBCDialect for Oracle, and pass to the JDBCUpsertTableSink
>>>>> when constructing via `JDBCOptions.Builder#setDialect`. In this way,
you
>>>>> don't need to recompile the source code of flink-jdbc.
>>>>>
>>>>> Best,
>>>>> Jark
>>>>>
>>>>> On Fri, 31 Jan 2020 at 19:28, Flavio Pompermaier <pompermaier@okkam.it>
>>>>> wrote:
>>>>>
>>>>>> Hi to all,
>>>>>> I was looking at the Flink SQL API's and I discovered that only a
few
>>>>>> drivers are supported [1], i.e. Mysql, Postgres and Derby. You could
have
>>>>>> problems only on the writing side of the connector (TableSink) because
you
>>>>>> need to adjust the override statement, but for the read part you
shouldn't
>>>>>> have problems with dialects...am I wrong?
>>>>>> And what am I supposed to do right now if I want to connect to Oracle
>>>>>> using the Table API? Do I have to use the low level JDBCInputFormat?
Is
>>>>>> there an easy way to connect to Oracle using the Table API without
the need
>>>>>> to modify and recompile the source code of Flink (just adding some
>>>>>> interface implementation in the application JAR)?
>>>>>>
>>>>>> [1]
>>>>>> https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connect.html#jdbc-connector
>>>>>>
>>>>>> Best,
>>>>>> Flavio
>>>>>>
>>>>>
>>>>
>>>> --
>>>> Best, Jingsong Lee
>>>>
>>>
>>
>> --
>> Best, Jingsong Lee
>>
>

-- 
Best, Jingsong Lee

Mime
View raw message