关闭前复制 Occi::ResultSet Occi::Connection

Question

我正在使用 OCCI 和 C++ 从 Oracle 获取数据。该代码运行良好，但我注意到性能有所下降。发生这种情况是因为在 rset->next() 迭代中一些计算需要时间。这种延迟的影响是oracle连接池有一个连接忙。如果并发请求需要相同的计算，则池中的所有连接可能都处于 BUSY 状态。

     Statement *stmt = conn->createStatement (sqlQuery);

      ResultSet *rset = stmt->executeQuery ();
      while (rset->next ())
      {
        //Slow computation takes time
        compute()
      }

      stmt->closeResultSet (rset);

      conn->terminateStatement (stmt);
      env->terminateConnection (conn);

所以我的问题是：我可以复制 Occi::ResultSet（使用共享指针吗？）以便在复制后关闭连接并在释放连接后进行计算？

go_to_oracle( ResultSet &result) {
 Statement *stmt = conn->createStatement (sqlQuery);

  ResultSet *rset = stmt->executeQuery ();

  copy_rset_to_result;


  stmt->closeResultSet (rset);

  conn->terminateStatement (stmt);
  env->terminateConnection (conn);
}

my_method() {

 ResultSet *result = NULL
 go_to_oracle(result);
 //here connection is closed, but we have the data
 compute(result) // do this without have connection occupied

}

GitHub 上有可用的示例吗？

Answer 1

执行查询未检索数据。您使用 rset->next() 从服务器读取数据。因此，如果您终止连接 - 您将无法读取数据

Answer 2

无法关闭与数据库的连接并保存结果集 (occi::ResultSet) 供以后使用。原因之一是 occi::ResultSet::next 从数据库中检索数据。相反，您可以使用数组提取和用户分配的数据缓冲区来存储结果。

occi::ResultSet::setDataBuffer的使用示例：

oracle::occi::ResultSet* rs=nullptr;
//.....
// query
//.....
static const size_t max_numrows=5000;
char var_buf[max_numrows][7];
char sym_buf[max_numrows][9];
rs->setDataBuffer(1,var_buf,oracle::occi::OCCI_SQLT_STR,sizeof(var_buf[0]),(ub2*)0);
rs->setDataBuffer(2,sym_buf,oracle::occi::OCCI_SQLT_STR,sizeof(sym_buf[0]),(ub2*)0);
size_t fetch_count=0;
while(rs->next(max_numrows)==ResultSet::DATA_AVAILABLE)
{
    /* This would probably be an error as you would like
       the whole result to fit in the data buffer.*/
}
stmt->closeResultSet (rs);
conn->terminateStatement (stmt);
compute(var_buf,sym_buf);

请注意，数组提取在

中的作用类似于预取

Status next(
   unsigned int numRows =1);

每次调用最多提取 numRows。

关闭前复制 Occi::ResultSet Occi::Connection

Copy Occi::ResultSet before closing Occi::Connection

c++

oracle

occi

c++11