feat: port v2 branch optimize to main branch

rows.go

@@ -14,7 +14,7 @@ const invalidate = "☠☠☠ MEMORY OVERWRITTEN ☠☠☠ "
 // CSVColumnParser is a function which converts trimmed csv
 // column string to a []byte representation. Currently
 // transforms NULL to nil
-var CSVColumnParser = func(s string) []byte {
+var CSVColumnParser = func(s string) driver.Value {
 	switch {
 	case strings.ToLower(s) == "null":
 		return nil

rows_test.go

@@ -753,3 +753,53 @@ func ExampleRows_AddRows() {
 	// Output: scanned id: 1 and title: one
 	// scanned id: 2 and title: two
 }
+
+func TestNullScanFromCSV(t *testing.T) {
+
+	const query string = "select nullable from TableWithNulls"
+
+	db, mock, err := New()
+	if err != nil {
+		t.Fatalf("an error '%s' was not expected when opening a stub database connection", err)
+	}
+	defer db.Close()
+
+	rs := NewRows([]string{"nullable"}).AddRow(1).AddRow(nil).FromCSVString("null")
+
+	mock.ExpectQuery(query).WillReturnRows(rs)
+
+	var expectedResults = []sql.NullInt64{
+		{Valid: true, Int64: 1},
+		{Valid: false, Int64: 0},
+		{Valid: false, Int64: 0},
+	}
+
+	rows, err := db.Query(query)
+	if err != nil {
+		t.Fatalf("an error '%s' was not expected when querying a stub database connection", err)
+	}
+	defer rows.Close()
+
+	var actualResults []sql.NullInt64
+	for rows.Next() {
+		var ni sql.NullInt64
+		if err = rows.Scan(&ni); err != nil {
+			t.Fatalf("an error '%s' was not expected while scanning row from mocked recordset", err)
+		}
+		actualResults = append(actualResults, ni)
+	}
+
+	if len(expectedResults) != len(actualResults) {
+		t.Fatalf("unexpected row count: wanted %d, got %d", len(expectedResults), len(actualResults))
+	}
+
+	for i, v := range actualResults {
+		if v != expectedResults[i] {
+			t.Fatalf("unexpected value in row %d: wanted %v, got %v", i, expectedResults[i], v)
+		}
+	}
+
+	if err = mock.ExpectationsWereMet(); err != nil {
+		t.Fatal(err)
+	}
+}