flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <mj...@apache.org>
Subject Re: DataStream jdbc sink
Date Wed, 13 Jan 2016 19:51:04 GMT
Hi,

use JDBCOutputFormatBuilder to set all required parameters:

> JDBCOutputFormatBuilder builder = JDBCOutputFormat.buildJDBCOutputFormat();
> builder.setDBUrl(...)
> // and more
> 
> var.write(builder.finish, OL);

-Matthias


On 01/13/2016 06:21 PM, Traku traku wrote:
> Hi everyone.
> 
> I'm trying to migrate some code to flink 0.10 and I'm having a problem.
> 
> I try to create a custom sink to insert the data to a postgresql
> database. My code was this.
> 
> var.output(
>         // build and configure OutputFormat
>         JDBCOutputFormat
>                 .buildJDBCOutputFormat()
>                 .setDrivername("org.postgresql.Driver")
>                 .setDBUrl("jdbc:postgresql://127.0.0.1:5432/test
> <http://127.0.0.1:5432/test>")
>                 .setUsername("postgres")
>                 .setPassword("")
>                 .setQuery("insert into XXX  values  (?,?,?);") 
>                 .finish()
>         );
> 
> Could you help me?
> 
> Best regards.
> 
> 


Mime
View raw message