Update test and Exec method

Author: pdelewski

platform/backend_connectors/hydrolix_backend_connector.go

@@ -48,5 +48,10 @@ func (p *HydrolixBackendConnector) InstanceName() string {
 }
 
 func (p *HydrolixBackendConnector) Exec(ctx context.Context, query string, args ...interface{}) error {
-	return nil
+	if len(args) == 0 {
+		_, err := p.connection.ExecContext(ctx, query)
+		return err
+	}
+	_, err := p.connection.ExecContext(ctx, query, args...)
+	return err
 }

platform/ingest/hydrolixlowerer.go

@@ -156,7 +156,5 @@ func (l *HydrolixLowerer) LowerToDDL(
   },
   "events": %s
 }`, table.DatabaseName, table.Name, timeColumnName, columnsJSON.String(), partitioningJSON, eventJSON)
-
-	fmt.Println(result)
 	return []string{result}, nil
 }

platform/ingest/insert_test.go

@@ -480,25 +480,27 @@ func TestHydrolixIngest(t *testing.T) {
 
 			expectedStatements: []string{
 				fmt.Sprintf(`{
-  "schema": {
+"schema": {
     "project": "%s",
     "name": "test_index",
     "time_column": "ingest_time",
     "columns": [
-      { "name": "new_field", "type": "string" },
-      { "name": "ingest_time", "type": "datetime", "default": "NOW" }
-    ],
+  { "name": "@timestamp", "type": "DateTime64(3)", "metadata": "DEFAULT now64()" },
+  { "name": "attributes_values", "type": "Map(String,String)" },
+  { "name": "attributes_metadata", "type": "Map(String,String)" },
+  { "name": "new_field", "type": "Nullable(String)", "comment": "quesmaMetadataV1:fieldName=new_field" }
+],
     "partitioning": {
-      "strategy": "time",
-      "field": "ingest_time",
-      "granularity": "day"
-    }
+  "strategy": "time",
+  "field": "ingest_time",
+  "granularity": "day"
+},
   },
   "events": [
-    {
-      "new_field": "bar"
-    }
-  ]
+      {
+        "new_field": "bar"
+      }
+    ]
 }`, projectName),
 			},
 		},