在Katalon中如何将ab库DOCUMENT表动态DOCUMENT_ID插入bc库DOCUMENT_IC表

1. 捕获ab.dbo.DOCUMENT插入后的动态DOCUMENT_ID #

因为DOCUMENT_ID是系统自动生成（比如自增、触发器生成），必须在插入操作完成后立即获取这个值，且要保证是同一个数据库会话内的操作，否则可能拿到错误数据。不同数据库的获取语句不同，以下是常用场景的示例：

SQL Server场景示例 #

修改你现有的ab库插入关键字，加入获取ID的逻辑：

// 自定义关键字：插入ab库文档并返回生成的DOCUMENT_ID
def insertAbDocumentAndGetId() {
    // 用你已有的方法建立ab库连接
    def abConn = CustomKeywords.'your.db.package.DBConnector'.connect('ab_db_config')
    def stmt = abConn.createStatement()
    
    // 执行你的实际插入语句（替换成业务需要的字段和值）
    String insertSql = "INSERT INTO ab.dbo.DOCUMENT (doc_title, doc_content) VALUES ('测试文档', '测试内容')"
    stmt.executeUpdate(insertSql)
    
    // 获取当前会话刚生成的DOCUMENT_ID
    def rs = stmt.executeQuery("SELECT SCOPE_IDENTITY() AS DOCUMENT_ID")
    def docId = null
    if (rs.next()) {
        docId = rs.getInt("DOCUMENT_ID")
    }
    
    // 按你现有逻辑关闭资源
    rs.close()
    stmt.close()
    CustomKeywords.'your.db.package.DBConnector'.close(abConn)
    
    // 返回动态生成的ID
    return docId
}

其他数据库的获取语句参考：

• MySQL：SELECT 1937492
• Oracle：插入语句改为 INSERT INTO ab.dbo.DOCUMENT (...) VALUES (...) RETURNING DOCUMENT_ID INTO :docId（需用PreparedStatement处理参数）

2. 将捕获的ID传入bc.dbo.DOCUMENT_IC的插入操作 #

在测试用例中，先调用上述方法拿到动态ID，再传给bc库的插入关键字：

// 测试用例代码
def generatedDocId = CustomKeywords.'your.keywords.package.DocumentOps'.insertAbDocumentAndGetId()

// 调用bc库插入关键字，传入DOCUMENT_ID和其他业务参数
CustomKeywords.'your.keywords.package.DocumentICOps'.insertBcDocumentIC(generatedDocId, '附属参数值')

对应的bc库插入关键字要支持接收DOCUMENT_ID参数，优先用PreparedStatement避免SQL注入：

// 自定义关键字：插入bc库DOCUMENT_IC表
def insertBcDocumentIC(int docId, String otherFieldValue) {
    def bcConn = CustomKeywords.'your.db.package.DBConnector'.connect('bc_db_config')
    String insertSql = "INSERT INTO bc.dbo.DOCUMENT_IC (DOCUMENT_ID, attached_field) VALUES (?, ?)"
    def pstmt = bcConn.prepareStatement(insertSql)
    
    pstmt.setInt(1, docId)
    pstmt.setString(2, otherFieldValue)
    pstmt.executeUpdate()
    
    // 关闭资源
    pstmt.close()
    CustomKeywords.'your.db.package.DBConnector'.close(bcConn)
}

关键注意事项 #

• 必须保证插入ab库和获取ID是同一个数据库连接会话，否则像SCOPE_IDENTITY()这类会话级的函数会返回错误值
• 绝对不要直接把动态ID拼进SQL字符串，用PreparedStatement绑定参数可以避免SQL注入风险

内容的提问来源于stack exchange，提问作者user19610349