无法通过 SQL 数据仓库上的 JDBC 获取生成的密钥

Question

我的 Azure SQL 数据仓库数据库中有一个这样的表：

CREATE TABLE t_identity (
  id INTEGER IDENTITY (1, 1) NOT NULL,
  val INTEGER
)

现在，我想使用 JDBC 插入一行并获取生成的标识值。这适用于 SQL Server 和大多数其他数据库：

try (Connection c = DriverManager.getConnection(url, properties);
    Statement s = c.createStatement()) {

    s.executeUpdate("insert into t_identity (val) values (1)",
        Statement.RETURN_GENERATED_KEYS);
    try (ResultSet rs = s.getGeneratedKeys()) {
        while (rs.next())
            System.out.println(rs.getObject(1));
    }
}

但在 SQL 数据仓库上，它不起作用：

Exception in thread "main" com.microsoft.sqlserver.jdbc.SQLServerException: 'SCOPE_IDENTITY' is not a recognized built-in function name.
    at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDatabaseError(SQLServerException.java:264)
    at com.microsoft.sqlserver.jdbc.SQLServerStatement.getNextResult(SQLServerStatement.java:1585)
    at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:876)
    at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:776)
    at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7385)
    at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2750)
    at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:235)
    at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:210)
    at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeUpdate(SQLServerStatement.java:2060)
    at SQLServer.main(SQLServer.java:65)

其他方法（例如executeUpdate(String, String[])）也不起作用，因为它们委托给上述方法。

我了解 SQL 数据仓库不支持 SCOPE_IDENTITY() and similar functions，这似乎是 mssql-jdbc 驱动程序在幕后使用的：

<dependency>
    <groupId>com.microsoft.sqlserver</groupId>
    <artifactId>mssql-jdbc</artifactId>
    <version>6.5.2.jre8-preview</version>
</dependency>

但是有解决方法吗？

注意事项：

• 输出子句也不可用：https://docs.microsoft.com/en-us/sql/t-sql/queries/output-clause-transact-sql
• I've also filed a bug on Github for mssql-jdbc

Answer 1

解决方法是添加到您的插入查询中，然后选择 id。

insert into t_identity
(val)
select 'my value'
where not exists
(
select 1
from t_identity
where val = 'my value'
)

select id
from t_dan_identity
where val = 'my value'

Answer 2

您能否更详细地描述您的业务用例？如果您使用的是 JOOQ，我认为您的技术可能不匹配。

Azure SQL 数据仓库不适用于事务性工作负载。如果 JOOQ 只是维护一些参考行，那么我认为没有问题，但如果这是您的主要数据加载策略，您将不会获得好的结果。

这里有一些可能会有所帮助的阅读材料：

用例和反模式： https://blogs.msdn.microsoft.com/sqlcat/2017/09/05/azure-sql-data-warehouse-workload-patterns-and-anti-patterns/

解决方案模型（滚动到图表）：https://azure.microsoft.com/en-us/services/sql-data-warehouse/

数据加载最佳实践：https://docs.microsoft.com/en-us/azure/sql-data-warehouse/guidance-for-loading-data

数据加载模式和策略：https://blogs.msdn.microsoft.com/sqlcat/2017/05/17/azure-sql-data-warehouse-loading-patterns-and-strategies/