0

我正在尝试增量读取 SQL Server CDC 更改。在我的第一个间隔中,我查询

Statement statement = connection.createStatement();
String queryString = "SELECT * FROM cdc.fn_cdc_get_all_changes_dbo_mytable(sys.fn_cdc_get_min_lsn('dbo_mytable'), " +
  "sys.fn_cdc_get_max_lsn(), 'all') ORDER BY __$seqval";
ResultSet rs = statement.executeQuery(queryString);

现在我知道 __$start_lsn 是二进制(10)中的 LSN(日志序列号)。虽然我不明白如何将它作为 Java 类型读取,以便我可以将它包含在我的下一个查询中,以及我应该如何创建我的下一个查询,我想将 min_lsn 指定为我处理的最后一个 LSN。

4

1 回答 1

0

您可以使用多个选项从ResultSet

然后要创建一个新查询,请查看使用 aa PreparedStatement。有几个选项可用于根据您从初始查询中提取的类型设置数据。

于 2017-05-23T04:59:49.730 回答