Add some tests for invalid tables passed to Delete()

contracts.go

@@ -72,6 +72,20 @@ func NewTable(tableName string, ids ...string) Table {
 	}
 }
 
+func (t Table) validate() error {
+	if t.name == "" {
+		return fmt.Errorf("table name cannot be an empty string")
+	}
+
+	for _, fieldName := range t.idColumns {
+		if fieldName == "" {
+			return fmt.Errorf("ID columns cannot be empty strings")
+		}
+	}
+
+	return nil
+}
+
 func (t Table) insertMethodFor(dialect Dialect) insertMethod {
 	if len(t.idColumns) == 1 {
 		return dialect.InsertMethod()

ksql.go

@@ -402,6 +402,10 @@ func (c DB) Insert(
 		return fmt.Errorf("ksql: expected a valid pointer to struct as argument but received a nil pointer: %v", record)
 	}
 
+	if err := table.validate(); err != nil {
+		return fmt.Errorf("can't insert in ksql.Table: %s", err)
+	}
+
 	info, err := structs.GetTagInfo(t.Elem())
 	if err != nil {
 		return err
@@ -543,6 +547,10 @@ func (c DB) Delete(
 	table Table,
 	idOrRecord interface{},
 ) error {
+	if err := table.validate(); err != nil {
+		return fmt.Errorf("can't delete from ksql.Table: %s", err)
+	}
+
 	idMaps, err := normalizeIDsAsMaps(table.idColumns, []interface{}{idOrRecord})
 	if err != nil {
 		return err
@@ -678,15 +686,7 @@ func buildInsertQuery(
 		return "", nil, nil, err
 	}
 
-	if table.name == "" {
-		return "", nil, nil, fmt.Errorf("can't insert in ksql.Table: table name cannot be an empty string")
-	}
-
 	for _, fieldName := range table.idColumns {
-		if fieldName == "" {
-			return "", nil, nil, fmt.Errorf("can't insert in ksql.Table: ID columns cannot be empty strings")
-		}
-
 		field, found := recordMap[fieldName]
 		if !found {
 			continue

ksql_test.go

@@ -1103,6 +1103,28 @@ func TestDelete(t *testing.T) {
 				err := c.Delete(ctx, UsersTable, user)
 				assert.NotEqual(t, nil, err)
 			})
+
+			t.Run("should report error if table contains an empty ID name", func(t *testing.T) {
+				db, closer := connectDB(t, config)
+				defer closer.Close()
+
+				ctx := context.Background()
+				c := newTestDB(db, config.driver)
+
+				err := c.Delete(ctx, NewTable("users", ""), &User{Name: "fake-name"})
+				tt.AssertErrContains(t, err, "ksql.Table", "ID", "empty string")
+			})
+
+			t.Run("should report error if ksql.Table.name is empty", func(t *testing.T) {
+				db, closer := connectDB(t, config)
+				defer closer.Close()
+
+				ctx := context.Background()
+				c := newTestDB(db, config.driver)
+
+				err := c.Delete(ctx, NewTable("", "id"), &User{Name: "fake-name"})
+				tt.AssertErrContains(t, err, "ksql.Table", "table name", "empty string")
+			})
 		})
 	}
 }