diff options
| author | unknown <mskold@mysql.com> | 2004-07-23 13:13:50 +0200 |
|---|---|---|
| committer | unknown <mskold@mysql.com> | 2004-07-23 13:13:50 +0200 |
| commit | 206cc88b6933ecf2ee752afa466824c6ed3feb99 (patch) | |
| tree | c05a8b80f1a6ad7448f6eee37a34f83ffb3b08c0 | |
| parent | 564b2736a4b63dc17237380bd4403ecd2d70072d (diff) | |
| download | mariadb-git-206cc88b6933ecf2ee752afa466824c6ed3feb99.tar.gz | |
Changed bulk insert to only be statement wise
| -rw-r--r-- | sql/ha_ndbcluster.cc | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/sql/ha_ndbcluster.cc b/sql/ha_ndbcluster.cc index 82445f175e7..ce452222fb9 100644 --- a/sql/ha_ndbcluster.cc +++ b/sql/ha_ndbcluster.cc @@ -1233,8 +1233,6 @@ int ha_ndbcluster::update_row(const byte *old_data, byte *new_data) DBUG_RETURN(read_res); } // Insert new row - rows_inserted= 0; - rows_to_insert= 1; int insert_res= write_row(new_data); if (!insert_res) { @@ -1338,7 +1336,7 @@ int ha_ndbcluster::delete_row(const byte *record) /* We are scanning records and want to delete the record that was just found, call deleteTuple on the cursor - to take over the lock to a new updatedelete operation + to take over the lock to a new delete operation And thus setting the primary key of the record from the active record in cursor */ @@ -2010,6 +2008,8 @@ void ha_ndbcluster::start_bulk_insert(ha_rows rows) int ha_ndbcluster::end_bulk_insert() { DBUG_ENTER("end_bulk_insert"); + rows_inserted= 0; + rows_to_insert= 1; DBUG_RETURN(0); } @@ -2716,7 +2716,7 @@ ha_ndbcluster::ha_ndbcluster(TABLE *table_arg): HA_NO_BLOBS), m_use_write(false), retrieve_all_fields(FALSE), - rows_to_insert(0), + rows_to_insert(1), rows_inserted(0), bulk_insert_rows(1024), ops_pending(0) |