diff options
Diffstat (limited to 'project2/sql/sqlBulkLoad.cpp')
| -rw-r--r-- | project2/sql/sqlBulkLoad.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/project2/sql/sqlBulkLoad.cpp b/project2/sql/sqlBulkLoad.cpp index 8787d3e..813323c 100644 --- a/project2/sql/sqlBulkLoad.cpp +++ b/project2/sql/sqlBulkLoad.cpp @@ -25,12 +25,12 @@ class SqlBulkLoad : public Task { void execute(ExecContext * ec) const { - const DB::Connection & wdb = db->getWritable(); - wdb.beginBulkUpload(targetTable(ec), extras(ec)); + auto wdb = db->getWritable(); + wdb->beginBulkUpload(targetTable(ec), extras(ec)); ScopeObject tidy([]{}, - [&]{ wdb.endBulkUpload(NULL); }, - [&]{ wdb.endBulkUpload("Stack unwind in progress"); }); - stream->runStream(boost::bind(&DB::Connection::bulkUploadData, &wdb, _1, _2), ec); + [&]{ wdb->endBulkUpload(NULL); }, + [&]{ wdb->endBulkUpload("Stack unwind in progress"); }); + stream->runStream(boost::bind(&DB::Connection::bulkUploadData, wdb.get(), _1, _2), ec); } const Variable dataSource; |