flink sql 怎么获取到oracle 自增ID ？
以下为热心网友提供的参考意见
在Flink SQL中，获取Oracle自增ID可以通过以下步骤实现：
- 首先，你需要在你的Flink SQL环境中启用对Oracle的支持。这通常需要在创建表的时候指定
'oracle'作为存储引擎。例如：
CREATE TABLE my_table (
id INT,
name STRING,
PRIMARY KEY(id) NOT ENFORCED
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:oracle:thin:@localhost:1521:xe',
'table-name' = 'my_table',
'username' = 'my_user',
'password' = 'my_password',
'sink.buffer-flush.max-rows' = '1000',
'sink.buffer-flush.interval' = '1s',
'sink.max-retries' = '3'
);
- 然后，你可以在插入数据时获取到自增ID。在Oracle中，当你向表中插入一条新记录时，你可以使用
ROWNUM来获取这条记录的自增ID。例如：
INSERT INTO my_table (name) VALUES ('John');
SELECT id FROM my_table WHERE name = 'John';
在这个例子中，当你插入一条名为’John’的新记录后，你可以通过查询my_table表来获取这条记录的自增ID。注意，由于这是Oracle的特性，所以这个操作只能在Oracle数据库上执行。
以下为热心网友提供的参考意见
在 Flink SQL 中，要获取 Oracle 自增 ID，可以使用以下方法：
- 首先，确保已经创建了一个源表（source table），用于从 Oracle 数据库中读取数据。例如：
CREATE TABLE oracle_source (
id INT,
name STRING,
age INT
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:oracle:thin:@localhost:1521:orcl',
'table-name' = 'your_table_name',
'username' = 'your_username',
'password' = 'your_password',
'driver' = 'oracle.jdbc.driver.OracleDriver'
);
- 然后，创建一个目标表（sink table），用于将处理后的数据写入到其他系统或存储。例如：
CREATE TABLE sink_table (
id INT,
name STRING,
age INT,
auto_increment_id BIGINT
) WITH (
'connector' = '...', -- 根据需要选择合适的连接器，如 Kafka、JDBC 等
...
);
- 接下来，编写一个 Flink SQL 查询，从源表中读取数据，并将自增 ID 添加到目标表中。例如：
INSERT INTO sink_table
SELECT id, name, age, id AS auto_increment_id FROM oracle_source;
这样，Flink SQL 查询就会从 Oracle 数据库中获取自增 ID，并将其添加到目标表中。注意，这里的自增 ID 就是源表中的 id 字段。
转转请注明出处：https://www.yunxiaoer.com/177236.html
