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

时间：2024-12-05 10:45:40

数据湖探索 DLI

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

参考使用gsql命令行客户端连接DWS集群连接已创建的DWS集群。
执行以下命令连接DWS集群的默认数据库“gaussdb”：
```
gsql -d gaussdb -h DWS集群连接地址 -U dbadmin -p 8000 -W password -r
```
- gaussdb：DWS集群默认数据库。
- DWS集群连接地址：请参见获取集群连接地址进行获取。如果通过公网地址连接，请指定为集群“公网访问地址”或“公网访问域名 ”，如果通过内网地址连接，请指定为集群“内网访问地址”或“内网访问域名”。如果通过弹性负载均衡连接，请指定为“弹性负载均衡地址”。
- dbadmin：创建集群时设置的默认管理员用户名。
- password ：默认管理员用户的密码。
在命令行窗口输入以下命令创建数据库“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 qualified_cars;
CREATE TABLE qualified_cars
(
    car_id VARCHAR, 
    car_owner VARCHAR,
    car_age INTEGER ,
    average_speed FLOAT8,
    total_miles FLOAT8
);

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

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