当前位置:网站首页>Flinksql read / write PgSQL
Flinksql read / write PgSQL
2022-07-07 05:44:00 【zs_ bigdata】
One . Code
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/ database ',\n" +
" 'username' = 'xx', " +
" 'password' = 'xxxx', " +
" 'table-name' = 'schema name . Table name '\n" +
")"
);
2 Step on the pit
If pgsql Used schema,name At this time, the table name needs `` escape , Otherwise, we will not find medical object
// `medical.hospital_department` Must escape
tableEnv.executeSql("select id,name from `medical.hospital_department`").print();
边栏推荐
- 淘宝商品详情页API接口、淘宝商品列表API接口,淘宝商品销量API接口,淘宝APP详情API接口,淘宝详情API接口
- Common skills and understanding of SQL optimization
- 5阶多项式轨迹
- App clear data source code tracking
- EMMC打印cqhci: timeout for tag 10提示分析与解决
- 拼多多新店如何获取免费流量,需要从哪些环节去优化,才能有效提升店内免费流量
- 论文阅读【Open-book Video Captioning with Retrieve-Copy-Generate Network】
- 4. Object mapping Mapster
- 5. Data access - entityframework integration
- Initial experience of annotation
猜你喜欢
What is dependency injection (DI)
CVE-2021-3156 漏洞复现笔记
The 2022 China low / no code Market Research and model selection evaluation report was released
Five core elements of architecture design
Message queue: how to deal with message backlog?
基于NCF的多模块协同实例
论文阅读【Open-book Video Captioning with Retrieve-Copy-Generate Network】
English grammar_ Noun possessive
High voltage leakage relay bld-20
分布式事务解决方案之2PC
随机推荐
Mybaits之多表查询(联合查询、嵌套查询)
JVM the truth you need to know
Hcip seventh operation
架构设计的五个核心要素
Leakage relay jelr-250fg
1.AVL树:左右旋-bite
What is message queuing?
AI face editor makes Lena smile
English语法_名词 - 所有格
sql优化常用技巧及理解
JSP setting header information export to excel
数据中心为什么需要一套基础设施可视化管理系统
5. Data access - entityframework integration
C nullable type
Hcip eighth operation
"Multimodal" concept
Common skills and understanding of SQL optimization
Unity keeps the camera behind and above the player
力扣102题:二叉树的层序遍历
Go 語言的 Context 詳解