负载均衡

当部署多个 FE 节点时,用户可以在多个 FE 之上部署负载均衡层来实现 Doris 的高可用。

代码实现

自己在应用层代码进行重试和负载均衡。比如发现一个连接挂掉,就自动在其他连接上进行重试。应用层代码重试需要应用自己配置多个 doris 前端节点地址。

JDBC Connector

如果使用 mysql jdbc connector 来连接 Doris,可以使用 jdbc 的自动重试机制:

1. jdbc:mysql:loadbalance://[host:port],[host:port].../[database][?propertyName1][=propertyValue1][&propertyName2][=propertyValue

详细可以参考Mysql官网文档

ProxySQL 方式

ProxySQL是灵活强大的MySQL代理层, 是一个能实实在在用在生产环境的MySQL中间件,可以实现读写分离,支持 Query 路由功能,支持动态指定某个 SQL 进行 cache,支持动态加载配置、故障切换和一些 SQL的过滤功能。

Doris 的 FE 进程负责接收用户连接和查询请求,其本身是可以横向扩展且高可用的,但是需要用户在多个 FE 上架设一层 proxy,来实现自动的连接负载均衡。

安装ProxySQL (yum方式)

1. 配置yum源
2. # vim /etc/yum.repos.d/proxysql.repo
3. [proxysql_repo]
4. name= ProxySQL YUM repository
5. baseurl=http://repo.proxysql.com/ProxySQL/proxysql-1.4.x/centos/\$releasever
6. gpgcheck=1
7. gpgkey=http://repo.proxysql.com/ProxySQL/repo_pub_key

9. 执行安装
10. # yum clean all
11. # yum makecache
12. # yum -y install proxysql
13. 查看版本
14. # proxysql --version
15. ProxySQL version 1.4.13-15-g69d4207, codename Truls
16. 设置开机自启动
17. # systemctl enable proxysql
18. # systemctl start proxysql
19. # systemctl status proxysql
20. 启动后会监听两个端口, 默认为6032和6033。6032端口是ProxySQL的管理端口,6033是ProxySQL对外提供服务的端口 (即连接到转发后端的真正数据库的转发端口)。
21. # netstat -tunlp
22. Active Internet connections (only servers)
23. Proto Recv-Q Send-Q Local Address           Foreign Address         State       PID/Program name
24. tcp        0      0 0.0.0.0:6032            0.0.0.0:*               LISTEN      23940/proxysql
25. tcp        0      0 0.0.0.0:6033            0.0.0.0:*               LISTEN

ProxySQL 配置

ProxySQL 有配置文件 /etc/proxysql.cnf 和配置数据库文件/var/lib/proxysql/proxysql.db。这里需要特别注意:如果存在"proxysql.db"文件(在/var/lib/proxysql目录下),则 ProxySQL 服务只有在第一次启动时才会去读取proxysql.cnf文件并解析;后面启动会就不会读取proxysql.cnf文件了!如果想要让proxysql.cnf 文件里的配置在重启 proxysql 服务后生效(即想要让 proxysql 重启时读取并解析 proxysql.cnf配置文件),则需要先删除 /var/lib/proxysql/proxysql.db数据库文件,然后再重启 proxysql 服务。这样就相当于初始化启动 proxysql 服务了,会再次生产一个纯净的 proxysql.db 数据库文件(如果之前配置了 proxysql 相关路由规则等,则就会被抹掉)

查看及修改配置文件

这里主要是几个参数,在下面已经注释出来了,可以根据自己的需要进行修改

1. # egrep -v "^#|^$" /etc/proxysql.cnf
2. datadir="/var/lib/proxysql"         #数据目录
3. admin_variables=
4. {
5. admin_credentials="admin:admin"  #连接管理端的用户名与密码
6. mysql_ifaces="0.0.0.0:6032"    #管理端口,用来连接proxysql的管理数据库
7. }
8. mysql_variables=
9. {
10. threads=4                #指定转发端口开启的线程数量
11. max_connections=2048
12. default_query_delay=0
13. default_query_timeout=36000000
14. have_compress=true
15. poll_timeout=2000
16. interfaces="0.0.0.0:6033"    #指定转发端口,用于连接后端mysql数据库的,相当于代理作用
17. default_schema="information_schema"
18. stacksize=1048576
19. server_version="5.5.30"        #指定后端mysql的版本
20. connect_timeout_server=3000
21. monitor_username="monitor"
22. monitor_password="monitor"
23. monitor_history=600000
24. monitor_connect_interval=60000
25. monitor_ping_interval=10000
26. monitor_read_only_interval=1500
27. monitor_read_only_timeout=500
28. ping_interval_server_msec=120000
29. ping_timeout_server=500
30. commands_stats=true
31. sessions_sort=true
32. connect_retries_on_failure=10
33. }
34. mysql_servers =
35. (
36. )
37. mysql_users:
38. (
39. )
40. mysql_query_rules:
41. (
42. )
43. scheduler=
44. (
45. )
46. mysql_replication_hostgroups=
47. (
48. )

连接 ProxySQL 管理端口测试

1. # mysql -uadmin -padmin -P6032 -hdoris01
2. 查看main库(默认登陆后即在此库)的global_variables表信息
3. MySQL [(none)]> show databases;
4. +-----+---------------+-------------------------------------+
5. | seq | name          | file                                |
6. +-----+---------------+-------------------------------------+
7. | 0   | main          |                                     |
8. | 2   | disk          | /var/lib/proxysql/proxysql.db       |
9. | 3   | stats         |                                     |
10. | 4   | monitor       |                                     |
11. | 5   | stats_history | /var/lib/proxysql/proxysql_stats.db |
12. +-----+---------------+-------------------------------------+
13. 5 rows in set (0.000 sec)
14. MySQL [(none)]> use main;
15. Reading table information for completion of table and column names
16. You can turn off this feature to get a quicker startup with -A

18. Database changed
19. MySQL [main]> show tables;
20. +--------------------------------------------+
21. | tables                                     |
22. +--------------------------------------------+
23. | global_variables                           |
24. | mysql_collations                           |
25. | mysql_group_replication_hostgroups         |
26. | mysql_query_rules                          |
27. | mysql_query_rules_fast_routing             |
28. | mysql_replication_hostgroups               |
29. | mysql_servers                              |
30. | mysql_users                                |
31. | proxysql_servers                           |
32. | runtime_checksums_values                   |
33. | runtime_global_variables                   |
34. | runtime_mysql_group_replication_hostgroups |
35. | runtime_mysql_query_rules                  |
36. | runtime_mysql_query_rules_fast_routing     |
37. | runtime_mysql_replication_hostgroups       |
38. | runtime_mysql_servers                      |
39. | runtime_mysql_users                        |
40. | runtime_proxysql_servers                   |
41. | runtime_scheduler                          |
42. | scheduler                                  |
43. +--------------------------------------------+
44. 20 rows in set (0.000 sec)

ProxySQL 配置后端 Doris FE

使用 insert 语句添加主机到 mysql_servers 表中,其中:hostgroup_id 为10表示写组,为20表示读组,我们这里不需要读写分离,无所谓随便设置哪一个都可以。

1. [root@mysql-proxy ~]# mysql -uadmin -padmin -P6032 -h127.0.0.1
2. ............
3. MySQL [(none)]> insert into mysql_servers(hostgroup_id,hostname,port) values(10,'192.168.9.211',9030);
4. Query OK, 1 row affected (0.000 sec)

6. MySQL [(none)]> insert into mysql_servers(hostgroup_id,hostname,port) values(10,'192.168.9.212',9030);
7. Query OK, 1 row affected (0.000 sec)

9. MySQL [(none)]> insert into mysql_servers(hostgroup_id,hostname,port) values(10,'192.168.9.213',9030);
10. Query OK, 1 row affected (0.000 sec)

12. 如果在插入过程中,出现报错:
13. ERROR 1045 (#2800): UNIQUE constraint failed: mysql_servers.hostgroup_id, mysql_servers.hostname, mysql_servers.port

15. 说明可能之前就已经定义了其他配置,可以清空这张表 或者 删除对应host的配置
16. MySQL [(none)]> select * from mysql_servers;
17. MySQL [(none)]> delete from mysql_servers;
18. Query OK, 6 rows affected (0.000 sec)

20. 查看这3个节点是否插入成功,以及它们的状态。
21. MySQL [(none)]> select * from mysql_servers\G;
22. *************************** 1. row ***************************
23. hostgroup_id: 10
24. hostname: 192.168.9.211
25. port: 9030
26. status: ONLINE
27. weight: 1
28. compression: 0
29. max_connections: 1000
30. max_replication_lag: 0
31. use_ssl: 0
32. max_latency_ms: 0
33. comment:
34. *************************** 2. row ***************************
35. hostgroup_id: 10
36. hostname: 192.168.9.212
37. port: 9030
38. status: ONLINE
39. weight: 1
40. compression: 0
41. max_connections: 1000
42. max_replication_lag: 0
43. use_ssl: 0
44. max_latency_ms: 0
45. comment:
46. *************************** 3. row ***************************
47. hostgroup_id: 10
48. hostname: 192.168.9.213
49. port: 9030
50. status: ONLINE
51. weight: 1
52. compression: 0
53. max_connections: 1000
54. max_replication_lag: 0
55. use_ssl: 0
56. max_latency_ms: 0
57. comment:
58. 6 rows in set (0.000 sec)

60. ERROR: No query specified

62. 如上修改后,加载到RUNTIME,并保存到disk,下面两步非常重要,不然退出以后你的配置信息就没了,必须保存
63. MySQL [(none)]> load mysql servers to runtime;
64. Query OK, 0 rows affected (0.006 sec)

66. MySQL [(none)]> save mysql servers to disk;
67. Query OK, 0 rows affected (0.348 sec)

监控Doris FE节点配置

添 doris fe 节点之后,还需要监控这些后端节点。对于后端多个FE高可用负载均衡环境来说,这是必须的,因为 ProxySQL 需要通过每个节点的 read_only 值来自动调整

它们是属于读组还是写组。

首先在后端master主数据节点上创建一个用于监控的用户名

1. 在doris fe master主数据库节点行执行:
2. # mysql -P9030 -uroot -p
3. mysql> create user monitor@'192.168.9.%' identified by 'P@ssword1!';
4. Query OK, 0 rows affected (0.03 sec)
5. mysql> grant ADMIN_PRIV on *.* to monitor@'192.168.9.%';
6. Query OK, 0 rows affected (0.02 sec)

8. 然后回到mysql-proxy代理层节点上配置监控
9. # mysql -uadmin -padmin -P6032 -h127.0.0.1
10. MySQL [(none)]> set mysql-monitor_username='monitor';
11. Query OK, 1 row affected (0.000 sec)

13. MySQL [(none)]> set mysql-monitor_password='P@ssword1!';
14. Query OK, 1 row affected (0.000 sec)

16. 修改后,加载到RUNTIME,并保存到disk
17. MySQL [(none)]> load mysql variables to runtime;
18. Query OK, 0 rows affected (0.001 sec)

20. MySQL [(none)]> save mysql variables to disk;
21. Query OK, 94 rows affected (0.079 sec)

23. 验证监控结果:ProxySQL监控模块的指标都保存在monitor库的log表中。
24. 以下是连接是否正常的监控(对connect指标的监控):
25. 注意:可能会有很多connect_error,这是因为没有配置监控信息时的错误,配置后如果connect_error的结果为NULL则表示正常。
26. MySQL [(none)]> select * from mysql_server_connect_log;
27. +---------------+------+------------------+-------------------------+---------------+
28. | hostname      | port | time_start_us    | connect_success_time_us | connect_error |
29. +---------------+------+------------------+-------------------------+---------------+
30. | 192.168.9.211 | 9030 | 1548665195883957 | 762                     | NULL          |
31. | 192.168.9.212 | 9030 | 1548665195894099 | 399                     | NULL          |
32. | 192.168.9.213 | 9030 | 1548665195904266 | 483                     | NULL          |
33. | 192.168.9.211 | 9030 | 1548665255883715 | 824                     | NULL          |
34. | 192.168.9.212 | 9030 | 1548665255893942 | 656                     | NULL          |
35. | 192.168.9.211 | 9030 | 1548665495884125 | 615                     | NULL          |
36. | 192.168.9.212 | 9030  | 1548665495894254 | 441                     | NULL          |
37. | 192.168.9.213 | 9030 | 1548665495904479 | 638                     | NULL          |
38. | 192.168.9.211 | 9030 | 1548665512917846 | 487                     | NULL          |
39. | 192.168.9.212 | 9030 | 1548665512928071 | 994                     | NULL          |
40. | 192.168.9.213 | 9030 | 1548665512938268 | 613                     | NULL          |
41. +---------------+------+------------------+-------------------------+---------------+
42. 20 rows in set (0.000 sec)
43. 以下是对心跳信息的监控(对ping指标的监控)
44. MySQL [(none)]> select * from mysql_server_ping_log;
45. +---------------+------+------------------+----------------------+------------+
46. | hostname      | port | time_start_us    | ping_success_time_us | ping_error |
47. +---------------+------+------------------+----------------------+------------+
48. | 192.168.9.211 | 9030 | 1548665195883407 | 98                   | NULL       |
49. | 192.168.9.212 | 9030 | 1548665195885128 | 119                  | NULL       |
50. ...........
51. | 192.168.9.213 | 9030 | 1548665415889362 | 106                  | NULL       |
52. | 192.168.9.213 | 9030 | 1548665562898295 | 97                   | NULL       |
53. +---------------+------+------------------+----------------------+------------+
54. 110 rows in set (0.001 sec)

56. read_only日志此时也为空(正常来说,新环境配置时,这个只读日志是为空的)
57. MySQL [(none)]> select * from mysql_server_read_only_log;
58. Empty set (0.000 sec)

60. 3个节点都在hostgroup_id=10的组中。
61. 现在,将刚才mysql_replication_hostgroups表的修改加载到RUNTIME生效。
62. MySQL [(none)]> load mysql servers to runtime;
63. Query OK, 0 rows affected (0.003 sec)

65. MySQL [(none)]> save mysql servers to disk;
66. Query OK, 0 rows affected (0.361 sec)

68. 现在看结果
69. MySQL [(none)]> select hostgroup_id,hostname,port,status,weight from mysql_servers;
70. +--------------+---------------+------+--------+--------+
71. | hostgroup_id | hostname      | port | status | weight |
72. +--------------+---------------+------+--------+--------+
73. | 10           | 192.168.9.211 | 9030 | ONLINE | 1      |
74. | 20           | 192.168.9.212 | 9030 | ONLINE | 1      |
75. | 20           | 192.168.9.213 | 9030 | ONLINE | 1      |
76. +--------------+---------------+------+--------+--------+
77. 3 rows in set (0.000 sec)

配置Doris用户

上面的所有配置都是关于后端 Doris FE 节点的,现在可以配置关于 SQL 语句的,包括:发送 SQL 语句的用户、SQL 语句的路由规则、SQL 查询的缓存、SQL 语句的重写等等。

本小节是 SQL 请求所使用的用户配置,例如 root 用户。这要求我们需要先在后端 Doris FE 节点添加好相关用户。这里以 root 和 doris 两个用户名为例.

1. 首先,在Doris FE master主数据库节点上执行:
2. # mysql -P9030 -uroot -p
3. .........
4. mysql> create user doris@'%' identified by 'P@ssword1!';
5. Query OK, 0 rows affected, 1 warning (0.04 sec)

7. mysql> grant ADMIN_PRIV on *.* to doris@'%';
8. Query OK, 0 rows affected, 1 warning (0.03 sec)

11. 然后回到mysql-proxy代理层节点,配置mysql_users表,将刚才的两个用户添加到该表中。
12. admin> insert into mysql_users(username,password,default_hostgroup) values('root','',10);
13. Query OK, 1 row affected (0.001 sec)

15. admin> insert into mysql_users(username,password,default_hostgroup) values('doris','P@ssword1!',10);
16. Query OK, 1 row affected (0.000 sec)

18. 加载用户到运行环境中,并将用户信息保存到磁盘
19. admin> load mysql users to runtime;
20. Query OK, 0 rows affected (0.001 sec)

22. admin> save mysql users to disk;
23. Query OK, 0 rows affected (0.108 sec)

25. mysql_users表有不少字段,最主要的三个字段为username、password和default_hostgroup:
26. -  username:前端连接ProxySQL,以及ProxySQL将SQL语句路由给MySQL所使用的用户名。
27. -  password:用户名对应的密码。可以是明文密码,也可以是hash密码。如果想使用hash密码,可以先在某个MySQL节点上执行
28. select password(PASSWORD),然后将加密结果复制到该字段。
29. -  default_hostgroup:该用户名默认的路由目标。例如,指定root用户的该字段值为10时,则使用root用户发送的SQL语句默认
30. 情况下将路由到hostgroup_id=10组中的某个节点。

32. admin> select * from mysql_users\G
33. *************************** 1. row ***************************
34. username: root
35. password:
36. active: 1
37. use_ssl: 0
38. default_hostgroup: 10
39. default_schema: NULL
40. schema_locked: 0
41. transaction_persistent: 1
42. fast_forward: 0
43. backend: 1
44. frontend: 1
45. max_connections: 10000
46. *************************** 2. row ***************************
47. username: doris
48. password: P@ssword1!
49. active: 1
50. use_ssl: 0
51. default_hostgroup: 10
52. default_schema: NULL
53. schema_locked: 0
54. transaction_persistent: 1
55. fast_forward: 0
56. backend: 1
57. frontend: 1
58. max_connections: 10000
59. 2 rows in set (0.000 sec)

61. 虽然这里没有详细介绍mysql_users表,但只有active=1的用户才是有效的用户。

63. MySQL [(none)]> load mysql users to runtime;
64. Query OK, 0 rows affected (0.001 sec)

66. MySQL [(none)]> save mysql users to disk;
67. Query OK, 0 rows affected (0.123 sec)

69. 这样就可以通过sql客户端,使用doris的用户名密码去连接了ProxySQL了

通过 ProxySQL 连接 Doris 进行测试

下面,分别使用 root 用户和 doris 用户测试下它们是否能路由到默认的 hostgroup_id=10 (它是一个写组)读数据。下面是通过转发端口 6033 连接的,连接的是转发到后端真正的数据库!

1. #mysql -uroot -p -P6033 -hdoris01 -e "show databases;"
2. Enter password:
3. ERROR 9001 (HY000) at line 1: Max connect timeout reached while reaching hostgroup 10 after 10000ms
4. 这个时候发现出错,并没有转发到后端真正的doris fe上
5. 通过日志看到有set autocommit=0 这样开启事务
6. 检查配置发现:
7. mysql-forward_autocommit=false
8. mysql-autocommit_false_is_transaction=false
9. 我们这里不需要读写分离,只需要将这两个参数通过下面语句直接搞成true就可以了
10. mysql> UPDATE global_variables SET variable_value='true' WHERE variable_name='mysql-forward_autocommit';
11. Query OK, 1 row affected (0.00 sec)

13. mysql> UPDATE global_variables SET variable_value='true' WHERE variable_name='mysql-autocommit_false_is_transaction';
14. Query OK, 1 row affected (0.01 sec)

16. mysql>  LOAD MYSQL VARIABLES TO RUNTIME;
17. Query OK, 0 rows affected (0.00 sec)

19. mysql> SAVE MYSQL VARIABLES TO DISK;
20. Query OK, 98 rows affected (0.12 sec)

22. 然后我们在重新试一下,显示成功
23. [root@doris01 ~]# mysql -udoris -pP@ssword1! -P6033 -h192.168.9.211  -e "show databases;"
24. Warning: Using a password on the command line interface can be insecure.
25. +--------------------+
26. | Database           |
27. +--------------------+
28. | doris_audit_db     |
29. | information_schema |
30. | retail             |
31. +--------------------+

OK,到此就结束了,你就可以用 Mysql 客户端,JDBC 等任何连接 mysql 的方式连接 ProxySQL 去操作你的 doris 了

Nginx TCP反向代理方式

概述

Nginx能够实现HTTP、HTTPS协议的负载均衡,也能够实现TCP协议的负载均衡。那么,问题来了,可不可以通过Nginx实现Apache Doris数据库的负载均衡呢?答案是:可以。接下来,就让我们一起探讨下如何使用Nginx实现Apache Doris的负载均衡。

环境准备

注意:使用Nginx实现Apache Doris数据库的负载均衡,前提是要搭建Apache Doris的环境,Apache Doris FE的IP和端口分别如下所示, 这里我是用一个FE来做演示的,多个FE只需要在配置里添加多个FE的IP地址和端口即可

通过Nginx访问MySQL的Apache Doris和端口如下所示。

1. IP: 172.31.7.119
2. 端口: 9030

安装依赖

1. sudo apt-get install build-essential
2. sudo apt-get install libpcre3 libpcre3-dev
3. sudo apt-get install zlib1g-dev
4. sudo apt-get install openssl libssl-dev

安装Nginx

1. sudo wget http://nginx.org/download/nginx-1.18.0.tar.gz
2. sudo tar zxvf nginx-1.18.0.tar.gz
3. cd nginx-1.18.0
4. sudo ./configure --prefix=/usr/local/nginx --with-stream --with-http_ssl_module --with-http_gzip_static_module --with-http_stub_status_module
5. sudo make && make install

配置反向代理

这里是新建了一个配置文件

1. vim /usr/local/nginx/conf/default.conf

然后在里面加上下面的内容

1. events {
2. worker_connections 1024;
3. }
4. stream {
5. upstream mysqld {
6. hash $remote_addr consistent;
7. server 172.31.7.119:9030 weight=1 max_fails=2 fail_timeout=60s;
8. ##注意这里如果是多个FE,加载这里就行了
9. }
10. ###这里是配置代理的端口,超时时间等
11. server {
12. listen 6030;
13. proxy_connect_timeout 300s;
14. proxy_timeout 300s;
15. proxy_pass mysqld;
16. }
17. }

启动Nginx

指定配置文件启动

1. cd /usr/local/nginx
2. /usr/local/nginx/sbin/nginx -c conf.d/default.conf

验证

1. mysql -uroot -P6030 -h172.31.7.119

参数解释:

  • -u 指定Doris用户名
  • -p 指定Doris密码,我这里密码是空,所以没有
  • -h 指定Nginx代理服务器IP
  • -P 指定端口
1. mysql -uroot -P6030 -h172.31.7.119
2. Welcome to the MySQL monitor.  Commands end with ; or \g.
3. Your MySQL connection id is 13
4. Server version: 5.1.0 Doris version 0.15.1-rc09-Unknown

6. Copyright (c) 2000, 2022, Oracle and/or its affiliates.

8. Oracle is a registered trademark of Oracle Corporation and/or its
9. affiliates. Other names may be trademarks of their respective
10. owners.

12. Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

14. mysql> show databases;
15. +--------------------+
16. | Database           |
17. +--------------------+
18. | information_schema |
19. | test               |
20. +--------------------+
21. 2 rows in set (0.00 sec)

23. mysql> use test;
24. Reading table information for completion of table and column names
25. You can turn off this feature to get a quicker startup with -A

27. Database changed
28. mysql> show tables;
29. +------------------+
30. | Tables_in_test   |
31. +------------------+
32. | dwd_product_live |
33. +------------------+
34. 1 row in set (0.00 sec)
35. mysql> desc dwd_product_live;
36. +-----------------+---------------+------+-------+---------+---------+
37. | Field           | Type          | Null | Key   | Default | Extra   |
38. +-----------------+---------------+------+-------+---------+---------+
39. | dt              | DATE          | Yes  | true  | NULL    |         |
40. | proId           | BIGINT        | Yes  | true  | NULL    |         |
41. | authorId        | BIGINT        | Yes  | true  | NULL    |         |
42. | roomId          | BIGINT        | Yes  | true  | NULL    |         |
43. | proTitle        | VARCHAR(1024) | Yes  | false | NULL    | REPLACE |
44. | proLogo         | VARCHAR(1024) | Yes  | false | NULL    | REPLACE |
45. | shopId          | BIGINT        | Yes  | false | NULL    | REPLACE |
46. | shopTitle       | VARCHAR(1024) | Yes  | false | NULL    | REPLACE |
47. | profrom         | INT           | Yes  | false | NULL    | REPLACE |
48. | proCategory     | BIGINT        | Yes  | false | NULL    | REPLACE |
49. | proPrice        | DECIMAL(18,2) | Yes  | false | NULL    | REPLACE |
50. | couponPrice     | DECIMAL(18,2) | Yes  | false | NULL    | REPLACE |
51. | livePrice       | DECIMAL(18,2) | Yes  | false | NULL    | REPLACE |
52. | volume          | BIGINT        | Yes  | false | NULL    | REPLACE |
53. | addedTime       | BIGINT        | Yes  | false | NULL    | REPLACE |
54. | offTimeUnix     | BIGINT        | Yes  | false | NULL    | REPLACE |
55. | offTime         | BIGINT        | Yes  | false | NULL    | REPLACE |
56. | createTime      | BIGINT        | Yes  | false | NULL    | REPLACE |
57. | createTimeUnix  | BIGINT        | Yes  | false | NULL    | REPLACE |
58. | amount          | DECIMAL(18,2) | Yes  | false | NULL    | REPLACE |
59. | views           | BIGINT        | Yes  | false | NULL    | REPLACE |
60. | commissionPrice | DECIMAL(18,2) | Yes  | false | NULL    | REPLACE |
61. | proCostPrice    | DECIMAL(18,2) | Yes  | false | NULL    | REPLACE |
62. | proCode         | VARCHAR(1024) | Yes  | false | NULL    | REPLACE |
63. | proStatus       | INT           | Yes  | false | NULL    | REPLACE |
64. | status          | INT           | Yes  | false | NULL    | REPLACE |
65. | maxPrice        | DECIMAL(18,2) | Yes  | false | NULL    | REPLACE |
66. | liveView        | BIGINT        | Yes  | false | NULL    | REPLACE |
67. | firstCategory   | BIGINT        | Yes  | false | NULL    | REPLACE |
68. | secondCategory  | BIGINT        | Yes  | false | NULL    | REPLACE |
69. | thirdCategory   | BIGINT        | Yes  | false | NULL    | REPLACE |
70. | fourCategory    | BIGINT        | Yes  | false | NULL    | REPLACE |
71. | minPrice        | DECIMAL(18,2) | Yes  | false | NULL    | REPLACE |
72. | liveVolume      | BIGINT        | Yes  | false | NULL    | REPLACE |
73. | liveClick       | BIGINT        | Yes  | false | NULL    | REPLACE |
74. | extensionId     | VARCHAR(128)  | Yes  | false | NULL    | REPLACE |
75. | beginTime       | BIGINT        | Yes  | false | NULL    | REPLACE |
76. | roomTitle       | TEXT          | Yes  | false | NULL    | REPLACE |
77. | beginTimeUnix   | BIGINT        | Yes  | false | NULL    | REPLACE |
78. | nickname        | TEXT          | Yes  | false | NULL    | REPLACE |
79. +-----------------+---------------+------+-------+---------+---------+
80. 40 rows in set (0.06 sec)