全部产品
云市场

创建MySQL表并读写数据

更新时间:2019-04-05 10:35:47

创建MySQL表

  1. create external table person (
  2. id int,
  3. name varchar(1023),
  4. age int
  5. ) tblproperties (
  6. table_mapping = "person"
  7. );

查询MySQL数据

  1. 登录DLA控制台

  2. 单击左侧导航栏的访问点管理,然后,登录DMS,进入DMS for Data Lake Analytics页面查询MySQL表(MySQL person表)数据。

    也可以通过MySQL客户端连接DLA中的数据库(hello_mysql_vpc_rds),读写MySQL数据。

    1. mysql> select * from person;
    2. +------+-------+------+
    3. | id | name | age |
    4. +------+-------+------+
    5. | 1 | james | 10 |
    6. | 2 | bond | 20 |
    7. | 3 | jack | 30 |
    8. | 4 | lucy | 40 |
    9. +------+-------+------+
    10. 4 rows in set (0.35 sec)

从OSS中清洗数据并写入RDS

在DLA中读取RDS数据,并不是RDS在DLA中的典型引用场景。因为RDS本身能承载的数据量有限,不适合大数据分析。更多的场景是在DLA中对存储在OSS/Table Store中的大数据进行分析,分析完成之后把结果数据回写到RDS中,供前台业务使用。

以前面的person表为例,通过以下语句把oss_db中customer的十条记录进行了一些转换,然后插入hello_mysql_vpc_rds.person表。

DLA如何读取OSS中的数据,请参见通过DLA读取OSS上的数据

  1. mysql> insert into hello_mysql_vpc_rds.person
  2. select c_custkey, c_name, c_custkey + 20 from oss_db.customer limit 10;
  3. +------+
  4. | rows |
  5. +------+
  6. | 10 |
  7. +------+
  8. 1 row in set (4.57 sec)
  9. mysql> select * from person;
  10. +------+--------------------+------+
  11. | id | name | age |
  12. +------+--------------------+------+
  13. | 1 | james | 10 |
  14. | 2 | bond | 20 |
  15. | 3 | jack | 30 |
  16. | 4 | lucy | 40 |
  17. | 1 | Customer#000000001 | 21 |
  18. | 3 | Customer#000000003 | 23 |
  19. | 5 | Customer#000000005 | 25 |
  20. | 2 | Customer#000000002 | 22 |
  21. | 4 | Customer#000000004 | 24 |
  22. | 7 | Customer#000000007 | 27 |
  23. | 6 | Customer#000000006 | 26 |
  24. | 9 | Customer#000000009 | 29 |
  25. | 8 | Customer#000000008 | 28 |
  26. | 10 | Customer#000000010 | 30 |
  27. +------+--------------------+------+
  28. 14 rows in set (0.26 sec)