| 259 | #endif |
| 260 | |
| 261 | void db_service::sql_select(const char* sql, db_query* query) |
| 262 | { |
| 263 | assert(sql && *sql); |
| 264 | |
| 265 | db_handle* db; |
| 266 | |
| 267 | std::list<db_handle*>::iterator it = dbpool_.begin(); |
| 268 | if (it == dbpool_.end()) { |
| 269 | db = db_create(); |
| 270 | } else { |
| 271 | db = *it; |
| 272 | dbpool_.erase(it); |
| 273 | } |
| 274 | |
| 275 | // �������̵߳�������� |
| 276 | db_ipc_request* ipc_req = NEW db_ipc_request(db, sql, query, true); |
| 277 | |
| 278 | // ���û��� ipc_service ������� |
| 279 | request(ipc_req); |
| 280 | } |
| 281 | |
| 282 | void db_service::sql_update(const char* sql, db_query* query) |
| 283 | { |