gbase数据、南大通用产品文档：GBase8a

USER()
函数说明
返回当前的GBase 8a MPP Cluster 用户和主机名。
示例
示例1：当前的用户为“root”，主机名为“172.168.83.11”。
gbase> SELECT USER() FROM dual;
+---------------------+
| USER()
|
+---------------------+
| root@172.168.83.11
|
+---------------------+
1 row in set
说明
这个值是用户连接的用户名和连接的主机名。它不同于CURRENT_
USER()的返回值。
示例2：用户可以精简到只剩用户名。

GBase 8a MPP Cluster 产品手册
5 数据库管理指南
文档版本953（2022-04-10）
南大通用数据技术股份有限公司
848
gbase> SELECT SUBSTRING_INDEX(USER(),'@',1) FROM dual;
+-------------------------------+
| SUBSTRING_INDEX(USER(),'@',1) |
+-------------------------------+
| root
|
+-------------------------------+
1 row in set
示例3：
USER()返回属于UTF8 字符集的值
（如果在安装时选择GBK 字符集的安
装包则返回属于GBK 字符集的值），因此用户也确保了“@”字符串文字可以
在该字符集中得到解释。
gbase> SELECT SUBSTRING_INDEX(USER(),'@',1) FROM dual;
+-------------------------------+
| SUBSTRING_INDEX(USER(),'@',1) |
+-------------------------------+
| root
|
+-------------------------------+
1 row in set

更改数据捕获函数是通过使用EXECUTE FUNCTION 语句运行的内置SQL函数。
您可以使用这些函数来控制数据捕获。
cdc_opensess() 函数的作用是：
返回CDC
会话ID，这是一个用于检索捕获数据的智能大对象文件描述符。
cdc_startcapture() 函数的作用是：指定要从中捕获数据的表。其他函数指定
开始或结束数据捕获。
您必须从客户端应用程序调用更改数据捕获函数。不能从数据库服务器中
运行的用户定义例程调用此函数。

取值：[1,UINT_MAX]
默认值：100000000
说明：导出到kafka 时，设置每条消息包含的最多数据行数。
8a 查询的结果集数据会根据该配置被分割成多条kafka 消息。默认值为
100000000 行数据。
修改方式：
可使用set 语句修改值也可在配置文件中修改值。
适用于session、
global
范围均可。