change that works

mariadb-corporation · Dec 9, 2017 · bb4ec76 · bb4ec76
1 parent b593a7c
commit bb4ec76
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/java/src/test/java/com/mariadb/columnstore/api/MillionRowTest.java b/java/src/test/java/com/mariadb/columnstore/api/MillionRowTest.java
@@ -21,15 +21,18 @@ public class MillionRowTest extends Common {
 
         // simple 1 row test
         ColumnStoreDriver d = new ColumnStoreDriver();
-        ColumnStoreBulkInsert b = d.createBulkInsert(DB_NAME, TABLE_NAME, (short)0, 0);
+        ColumnStoreBulkInsert b = null;
         int rows = 1000000;
         try {
-            for (int i=0; i<rows; ++i) {
-                b.setColumn(0, i);
-                b.setColumn(1, rows-i);
-                b.writeRow();
+            for (int j=0; j<1; ++j) {
+                b = d.createBulkInsert(DB_NAME, TABLE_NAME, (short)0, 0);
+                for (int i=0; i<rows; ++i) {
+                    b.setColumn(0, i);
+                    b.setColumn(1, rows-i);
+                    b.writeRow();
+                }
+                b.commit();                            
             }
-            b.commit();
         } catch (Exception e) {
             b.rollback();
             fail("Error during mcsapi write operations: " + e);