flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: Read data from Oracle using Flink SQL API
Date Thu, 06 Feb 2020 10:01:35 GMT
Should I open a JIRA to better document how to connect to an RDBMS that has
no "out-of-the-box" dialect?
I.e. Pass the dialect impl in the TableEnvionment.registerTableSource?

On Thu, Feb 6, 2020 at 10:53 AM Jingsong Li <jingsonglee0@gmail.com> wrote:

> 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
>


-- 
Flavio Pompermaier
Development Department

OKKAM S.r.l.
Tel. +(39) 0461 041809

Mime
View raw message