数据湖探索 DLI-从PostgreSQL CDC源表读取数据写入到DWS:步骤3：创建DWS数据库和表

时间：2024-05-20 09:43:43

步骤3：创建DWS数据库和表

连接已创建的DWS集群。
请参考使用gsql命令行客户端连接DWS集群。
执行以下命令连接DWS集群的默认数据库“gaussdb”：
```
gsql -d gaussdb -h DWS集群连接地址 -U dbadmin -p 8000 -W password -r
```
- gaussdb：DWS集群默认数据库。
- DWS集群连接地址：请参见获取集群连接地址进行获取。如果通过公网地址连接，请指定为集群“公网访问地址”或“公网访问域名 ”，如果通过内网地址连接，请指定为集群“内网访问地址”或“内网访问域名”。如果通过弹性负载均衡连接，请指定为“弹性负载均衡地址”。
- dbadmin：创建集群时设置的默认管理员用户名。
- -W：默认管理员用户的密码。
在命令行窗口输入以下命令创建数据库“testdwsdb”。
```
CREATE DATABASE testdwsdb;
```
执行以下命令，退出gaussdb数据库，连接新创建的数据库“testdwsdb”。
```
\q
gsql -d testdwsdb -h DWS集群连接地址 -U dbadmin -p 8000 -W password -r
```

执行以下命令创建表。

create schema test;
set current_schema= test;
drop table if exists dws_order;
CREATE TABLE dws_order
(
  order_id VARCHAR,
  order_channel VARCHAR,
  order_time VARCHAR,
  pay_amount FLOAT8,
  real_pay FLOAT8,
  pay_time VARCHAR,
  user_id VARCHAR,
  user_name VARCHAR,
  area_id VARCHAR
);

上一篇：数据湖探索 DLI-从PostgreSQL CDC源表读取数据写入到DWS:整体作业开发流程

下一篇：数据湖探索 DLI-从PostgreSQL CDC源表读取数据写入到DWS:整体作业开发流程