当前位置:网站首页>Flinksql 读写pgsql
Flinksql 读写pgsql
2022-07-06 23:51:00 【zs_bigdata】
一. 代码
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, EnvironmentSettings.inStreamingMode());
AbstractJdbcCatalog catalog = JdbcCatalogUtils.createCatalog(
"myPgsql",
"staging",
"username",
"password",
"jdbc:postgresql://xxx:port"
);
tableEnv.registerCatalog("myPgsql", catalog);
tableEnv.useCatalog("myPgsql");
tableEnv.useDatabase("staging");
boolean staging = catalog.tableExists(new ObjectPath("staging", "medical.hospital_department"));
System.out.println(staging);
System.out.println(Arrays.toString(tableEnv.listCatalogs()));
System.out.println(Arrays.toString(tableEnv.listDatabases()));
//System.out.println(Arrays.toString(tableEnv.listTables()));
tableEnv.executeSql("select id,name from `medical.hospital_department`").print();
//sql api
tableEnv.executeSql(
"CREATE TABLE hospital_position (\n" +
" id string,\n" +
" department_id string,\n" +
" waypoint_id STRING,\n" +
" zone_id STRING,\n" +
" PRIMARY KEY (id) NOT ENFORCED\n" +
") WITH (\n" +
" 'connector' = 'jdbc',\n" +
" 'url' = 'jdbc:postgresql://xxxxx:port/数据库',\n" +
" 'username' = 'xx', " +
" 'password' = 'xxxx', " +
" 'table-name' = 'schema名.表名'\n" +
")"
);
2 踩坑
如果pgsql使用了schema,name此时表名需要``转义,否则会报找不到medical object
// `medical.hospital_department` 一定要转义
tableEnv.executeSql("select id,name from `medical.hospital_department`").print();
边栏推荐
猜你喜欢
DJ-ZBS2漏电继电器
[binary tree] binary tree path finding
漏电继电器LLJ-100FS
不同网段之间实现GDB远程调试功能
高压漏电继电器BLD-20
EGR-20USCM接地故障继电器
Photo selector collectionview
Use Zhiyun reader to translate statistical genetics books
[论文阅读] Semi-supervised Left Atrium Segmentation with Mutual Consistency Training
Senior programmers must know and master. This article explains in detail the principle of MySQL master-slave synchronization, and recommends collecting
随机推荐
DJ-ZBS2漏电继电器
论文阅读【Sensor-Augmented Egocentric-Video Captioning with Dynamic Modal Attention】
np. random. Shuffle and np Use swapaxis or transfer with caution
The year of the tiger is coming. Come and make a wish. I heard that the wish will come true
As we media, what websites are there to download video clips for free?
Simple case of SSM framework
淘宝商品详情页API接口、淘宝商品列表API接口,淘宝商品销量API接口,淘宝APP详情API接口,淘宝详情API接口
[reading of the paper] a multi branch hybrid transformer network for channel terminal cell segmentation
Senior programmers must know and master. This article explains in detail the principle of MySQL master-slave synchronization, and recommends collecting
JHOK-ZBL1漏电继电器
Design, configuration and points for attention of network specified source multicast (SSM) simulation using OPNET
batch size设置技巧
A cool "ghost" console tool
Jhok-zbl1 leakage relay
"Multimodal" concept
分布式事务解决方案之TCC
【js组件】自定义select
实现网页内容可编辑
JVM(十九) -- 字节码与类的加载(四) -- 再谈类的加载器
[JS component] date display.