diff options
Diffstat (limited to 'project2/sql/sqlBulkLoad.cpp')
| -rw-r--r-- | project2/sql/sqlBulkLoad.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/project2/sql/sqlBulkLoad.cpp b/project2/sql/sqlBulkLoad.cpp index a8283b9..8787d3e 100644 --- a/project2/sql/sqlBulkLoad.cpp +++ b/project2/sql/sqlBulkLoad.cpp @@ -20,17 +20,17 @@ class SqlBulkLoad : public Task { void loadComplete(const CommonObjects * co) { - db = co->dataSource<RdbmsDataSource>(dataSource()); + db = co->dataSource<RdbmsDataSource>(dataSource(NULL)); } - void execute() const + void execute(ExecContext * ec) const { const DB::Connection & wdb = db->getWritable(); - wdb.beginBulkUpload(targetTable(), extras()); + 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)); + stream->runStream(boost::bind(&DB::Connection::bulkUploadData, &wdb, _1, _2), ec); } const Variable dataSource; |