在 JRuby 中,使用 JDBC 适配器可以覆盖插入并传入返回子句。棘手的部分是您并不总是知道此级别的主键是什么,因此您可能必须使用 ROWID 或请求返回所有列。
您最终会得到类似于以下内容的内容:
module Sequel
module JDBC
class Database
def execute_insert_with_returning(conn, sql, opts = {})
columns = opts[:key_columns] || ["ROWID"]
q = "{ call #{sql} returning #{columns.join(',')} into #{columns.collect {|_| '?'}.join(',')} }"
stmt = conn.prepare_call(q)
raise "Unable to prepare call for insert" if stmt.nil?
begin
columns.each_with_index do |_, index|
stmt.registerOutParameter(index+1, JavaSQL::Types::VARCHAR)
end
return nil if 0 == stmt.executeQuery
values = (1..columns.count).inject({}) do |memo, index|
key = columns[index-1].downcase.to_sym rescue nil
memo[key] = stmt.get_string(index) unless key.nil?
memo
end
values
ensure
stmt.close
end
end # #execute_insert_with_returning
alias execute_without_specialized_insert execute
def execute(sql, opts={}, &block)
if opts[:type] == :insert
synchronize(opts[:server]) do |conn|
execute_insert_with_returning conn, sql, opts
end
else
execute_without_specialized_insert sql, opts, &block
end
end # #execute
end # Database
end # JDBC
end # Sequel
我已经做了类似这样的事情,而且效果很好。我认为我们还必须覆盖 Sequel::Model 以便它将主键作为 opts[:key_columns] 传递,但我可能记错了。
这是一个完成工作的承重杂物。将其专门用于 Oracle JDBC 适配器并确保所有错误处理代码都来自原始执行语句会更优雅。考虑到时间,我很想得到更好的东西并将其归还给 Sequel 项目。