Details
-
Bug
-
Status: Closed (View Workflow)
-
Critical
-
Resolution: Fixed
-
10.2(EOL), 10.3(EOL)
-
None
Description
When using COM_STMT_BULK_EXECUTE , the first "couple" are not taken in account.
Statement stmt = sharedConnection.createStatement();
|
stmt.execute("CREATE TEMPORARY TABLE test_replace (id int not null primary key, active BOOLEAN)") |
stmt.execute("insert into test_replace values (1, false), (2, false), (3, false)"); |
|
|
try (PreparedStatement preparedStatement = sharedConnection.prepareStatement("replace into test_replace (id, active) values (?, ?)")) { |
preparedStatement.setInt(1, 1); |
preparedStatement.setBoolean(2, true); |
preparedStatement.addBatch();
|
preparedStatement.setInt(1, 2); |
preparedStatement.setBoolean(2, true); |
preparedStatement.addBatch();
|
preparedStatement.setInt(1, 3); |
preparedStatement.setBoolean(2, true); |
preparedStatement.addBatch();
|
preparedStatement.setInt(1, 4); |
preparedStatement.setBoolean(2, true); |
preparedStatement.addBatch();
|
preparedStatement.executeBatch();
|
}
|
expected in database :
1 true |
2 true |
3 true |
4 true |
but is
1 false |
2 true |
3 true |
4 true |
The byte send to server are ok, according to COM_STMT_BULK_EXECUTE protocol :
27 00 00 00 FA 01 00 00 00 80 FF 03 00 01 00 00 '............... |
01 00 00 00 00 01 00 02 00 00 00 00 01 00 03 00 ................ |
00 00 00 01 00 04 00 00 00 00 01 ........... |
(tested with server 10.3.7 and 10.2.14)
Attachments
Issue Links
- relates to
-
-
- Closed
-
static void test_bulk_replace(){int rc;MYSQL_STMT *stmt;MYSQL_BIND bind[2];MYSQL_ROW row;int i,id[]= {1, 2, 3, 4},val[]= {1, 1, 1, 1},count= sizeof(id)/sizeof(id[0]);MYSQL_RES *result;rc= mysql_query(mysql, "DROP TABLE IF EXISTS t1");myquery(rc);rc= mysql_query(mysql, "CREATE TABLE t1 (id int not null primary key, active int)");myquery(rc);rc= mysql_query(mysql, "insert into t1 values (1, 0), (2, 0), (3, 0)");myquery(rc);verify_affected_rows(3);stmt= mysql_stmt_init(mysql);rc= mysql_stmt_prepare(stmt, "replace into t1 (id, active) values (?, ?)", -1);check_execute(stmt, rc);memset(bind, 0, sizeof(bind));bind[0].buffer_type = MYSQL_TYPE_LONG;bind[0].buffer = (void *)id;bind[0].buffer_length = 0;bind[1].buffer_type = MYSQL_TYPE_LONG;bind[1].buffer = (void *)val;bind[1].buffer_length = 0;mysql_stmt_attr_set(stmt, STMT_ATTR_ARRAY_SIZE, (void*)&count);rc= mysql_stmt_bind_param(stmt, bind);check_execute(stmt, rc);rc= mysql_stmt_execute(stmt);check_execute(stmt, rc);mysql_stmt_close(stmt);rc= mysql_query(mysql, "SELECT active FROM t1");myquery(rc);result= mysql_store_result(mysql);mytest(result);i= 0;while ((row= mysql_fetch_row(result))){i++;DIE_IF(atoi(row[0]) != 1);}DIE_IF(i != 4);mysql_free_result(result);rc= mysql_query(mysql, "DROP TABLE t1");myquery(rc);}