...cs.Lock();otl_stream outStream(5000, "insert into test values(:f1<int>, :f2<char[20]>, ...", db);//构造数据并写缓冲区while(...){ outStream << x << "123";}cs.unlock();
//查询操作线程
C/C++ code
...cs.Lock();otl_stream inStream(5000, "select * from test where ...", db);//解析数据while(...){ inStream >> i; inStream >> str; ....}cs.unlock();
//删除操作线程
C/C++ code
...cs.Lock();otl_cursor::direct_exec(db, "delete from test where ...");cs.unlock();