Fix for CONPY-224:

If a bulk operation is executed and the statement doesn't need to
be reprepared, only array size has to be updated, since setting
the number of parameters (STMT_ATTR_PREBIND_PARAMS) will reset the
statement in Connector/C.

Author: 9EOR9

mariadb/mariadb_cursor.c

@@ -1168,10 +1168,13 @@ MrdbCursor_execute_bulk(MrdbCursor *self)
 
     /* If the server doesn't support bulk execution (< 10.2.6),
        we need to call a fallback routine */
+    if (self->reprepare)
+    {
+      mysql_stmt_attr_set(self->stmt, STMT_ATTR_PREBIND_PARAMS, &self->parseinfo.paramcount);
+      mysql_stmt_attr_set(self->stmt, STMT_ATTR_CB_USER_DATA, (void *)self);
+      mysql_stmt_attr_set(self->stmt, STMT_ATTR_CB_PARAM, mariadb_param_update);
+    }
     mysql_stmt_attr_set(self->stmt, STMT_ATTR_ARRAY_SIZE, &self->array_size);
-    mysql_stmt_attr_set(self->stmt, STMT_ATTR_PREBIND_PARAMS, &self->parseinfo.paramcount);
-    mysql_stmt_attr_set(self->stmt, STMT_ATTR_CB_USER_DATA, (void *)self);
-    mysql_stmt_attr_set(self->stmt, STMT_ATTR_CB_PARAM, mariadb_param_update);
 
     mysql_stmt_bind_param(self->stmt, self->params);
 

testing/test/integration/test_cursor.py

@@ -1432,6 +1432,39 @@ def test_conpy222(self):
         except Exception:
             pass
 
+    def test_conpy_224(self):
+
+        if is_maxscale():
+            self.skipTest("MAXSCALE doesn't support BULK yet")
+
+        cursor = self.connection.cursor()
+
+        cursor.execute("CREATE TEMPORARY TABLE test_inserttuple ("
+                       "id int, name varchar(64), "
+                       "city varchar(64))")
+
+        params = ((1, u"Jack", u"Boston"),
+                  (2, u"Martin", u"Ohio"),
+                  (3, u"James", u"Washington"),
+                  (4, u"Rasmus", u"Helsinki"),
+                  (5, u"Andrey", u"Sofia"))
+
+        cursor.executemany("INSERT INTO test_inserttuple VALUES (?,?,?)",
+                           params)
+
+        cursor.executemany("INSERT INTO test_inserttuple VALUES (?,?,?)",
+                           params)
+
+        cursor = self.connection.cursor()
+
+        cursor.execute("SELECT name FROM test_inserttuple ORDER BY id DESC")
+
+        row = cursor.fetchone()
+
+        self.assertEqual("Andrey", row[0])
+
+        del cursor
+
     def test_conpy91(self):
         with create_connection() as connection:
             with connection.cursor() as cursor: