Add tests for MySQL BIT and PostgreSQL BYTEA columns

Signed-off-by: Joern Bernhardt <[email protected]>

Author: McHunkyTrunk

src/test/java/io/vertx/ext/asyncsql/MySQLClientTest.java

@@ -20,13 +20,16 @@
 import io.vertx.core.Handler;
 import io.vertx.core.json.JsonArray;
 import io.vertx.core.json.JsonObject;
+import io.vertx.ext.sql.ResultSet;
 import io.vertx.ext.sql.SQLConnection;
 import io.vertx.ext.sql.UpdateResult;
 import io.vertx.ext.unit.Async;
 import io.vertx.ext.unit.TestContext;
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.Arrays;
+
 public class MySQLClientTest extends SQLTestBase {
 
 
@@ -93,6 +96,22 @@ public void testInsertedIds(TestContext context) {
     });
   }
 
+  protected String createByteArray1TableColumn() {
+    return "BIT(1)";
+  }
+
+  protected String createByteArray2TableColumn() {
+    return "BIT(2)";
+  }
+
+  protected String[] insertByteArray1Values() {
+    return new String[]{"B'1'", "B'0'", "B'1'"};
+  }
+
+  protected String[] insertByteArray2Values() {
+    return new String[]{"B'10'", "B'01'", "B'11'"};
+  }
+
   private void setupAutoIncrementTable(SQLConnection conn, Handler<AsyncResult<Void>> handler) {
     conn.execute("BEGIN",
         ar -> conn.execute("DROP TABLE IF EXISTS test_table",

src/test/java/io/vertx/ext/asyncsql/PostgreSQLClientTest.java

@@ -27,6 +27,7 @@
 import org.junit.Before;
 import org.junit.Test;
 
+import java.util.Arrays;
 import java.util.UUID;
 
 public class PostgreSQLClientTest extends SQLTestBase {
@@ -111,6 +112,22 @@ public void testUsingUUIDsInTables(TestContext context) {
     });
   }
 
+  protected String createByteArray1TableColumn() {
+    return "BYTEA";
+  }
+
+  protected String createByteArray2TableColumn() {
+    return "BYTEA";
+  }
+
+  protected String[] insertByteArray1Values() {
+    return new String[]{"E'\\001'", "E'\\\\000'", "E'\\\\001'"};
+  }
+
+  protected String[] insertByteArray2Values() {
+    return new String[]{"E'\\x2'", "E'\\x1'", "E'\\x3'"};
+  }
+
   private void setupAutoIncrementTable(SQLConnection conn, Handler<AsyncResult<Void>> handler) {
     conn.execute("BEGIN",
         ar -> conn.execute("DROP TABLE IF EXISTS test_table",

src/test/java/io/vertx/ext/asyncsql/SQLTestBase.java

@@ -28,6 +28,7 @@
 import io.vertx.ext.unit.TestContext;
 import org.junit.Test;
 
+import java.util.Arrays;
 import java.util.List;
 
 public abstract class SQLTestBase extends AbstractTestBase {