用Sql输出到oracle

classic Classic list List threaded Threaded
4 messages Options
Reply | Threaded
Open this post in threaded view
|

用Sql输出到oracle

Kyle Zhang
大家好,最近刚开始用flink,遇到一些问题。
我的场景是从kafka读数,group by之后输出到oracle,但是我看现在JdbcDialects只有mysql、postgres跟derby,大家oracle怎么用的。
现在我是把table转成stream再写到oracle里。
Reply | Threaded
Open this post in threaded view
|

Re: 用Sql输出到oracle

Dream-底限
自己加一个oracle的dialect

On Tue, May 26, 2020 at 11:42 AM Kyle Zhang <[hidden email]> wrote:

> 大家好,最近刚开始用flink,遇到一些问题。
> 我的场景是从kafka读数,group
> by之后输出到oracle,但是我看现在JdbcDialects只有mysql、postgres跟derby,大家oracle怎么用的。
> 现在我是把table转成stream再写到oracle里。
Reply | Threaded
Open this post in threaded view
|

Re: 用Sql输出到oracle

Benchao Li
Hi,

社区有人提过一个oracle的dialect实现,现在还没有merge,你可以参考一下[1].

[1] https://github.com/apache/flink/pull/11999

宇张 <[hidden email]> 于2020年5月26日周二 上午11:55写道:

> 自己加一个oracle的dialect
>
> On Tue, May 26, 2020 at 11:42 AM Kyle Zhang <[hidden email]>
> wrote:
>
> > 大家好,最近刚开始用flink,遇到一些问题。
> > 我的场景是从kafka读数,group
> > by之后输出到oracle,但是我看现在JdbcDialects只有mysql、postgres跟derby,大家oracle怎么用的。
> > 现在我是把table转成stream再写到oracle里。
>


--

Best,
Benchao Li
Reply | Threaded
Open this post in threaded view
|

Re: 用Sql输出到oracle

Leonard Xu
Hi,
JDBC支持Oracle 得到1.12了,1.11已经cut了,benchao说的那个PR暂时还没进,主要是社区在考虑dialect的种类是非常多的,希望将JdbcDialect插件化,以支持用户的各种dialect。

祝好,
Leonard Xu


> 在 2020年5月26日,11:57,Benchao Li <[hidden email]> 写道:
>
> Hi,
>
> 社区有人提过一个oracle的dialect实现,现在还没有merge,你可以参考一下[1].
>
> [1] https://github.com/apache/flink/pull/11999
>
> 宇张 <[hidden email]> 于2020年5月26日周二 上午11:55写道:
>
>> 自己加一个oracle的dialect
>>
>> On Tue, May 26, 2020 at 11:42 AM Kyle Zhang <[hidden email]>
>> wrote:
>>
>>> 大家好,最近刚开始用flink,遇到一些问题。
>>> 我的场景是从kafka读数,group
>>> by之后输出到oracle,但是我看现在JdbcDialects只有mysql、postgres跟derby,大家oracle怎么用的。
>>> 现在我是把table转成stream再写到oracle里。
>>
>
>
> --
>
> Best,
> Benchao Li