[Chore] Use defer to close rows in examples

examples/clickhouse_api/array.go

@@ -68,12 +68,13 @@ func ArrayInsertRead() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 		if err := rows.Scan(&col1, &col2); err != nil {
 			return err
 		}
 		fmt.Printf("row: col1=%v, col2=%v\n", col1, col2)
 	}
-	rows.Close()
 	return rows.Err()
 }

examples/clickhouse_api/external_data.go

@@ -63,6 +63,8 @@ func ExternalData() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 		var (
 			col1 uint8
@@ -72,7 +74,6 @@ func ExternalData() error {
 		rows.Scan(&col1, &col2, &col3)
 		fmt.Printf("col1=%d, col2=%s, col3=%v\n", col1, col2, col3)
 	}
-	rows.Close()
 
 	var count uint64
 	if err := conn.QueryRow(ctx, "SELECT COUNT(*) FROM external_table_1").Scan(&count); err != nil {

examples/clickhouse_api/map.go

@@ -20,8 +20,9 @@ package clickhouse_api
 import (
 	"context"
 	"fmt"
-	"github.com/ClickHouse/clickhouse-go/v2/lib/column/orderedmap"
 	"strconv"
+
+	"github.com/ClickHouse/clickhouse-go/v2/lib/column/orderedmap"
 )
 
 func MapInsertRead() error {
@@ -72,13 +73,15 @@ func MapInsertRead() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 		if err := rows.Scan(&col1, &col2, &col3); err != nil {
 			return err
 		}
 		fmt.Printf("row: col1=%v, col2=%v, col3=%v\n", col1, col2, col3)
 	}
-	rows.Close()
+
 	return rows.Err()
 }
 
@@ -124,13 +127,15 @@ func IterableOrderedMapInsertRead() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 		var col1 orderedmap.Map[string, string]
 		if err := rows.Scan(&col1); err != nil {
 			return err
 		}
 		fmt.Printf("row: col1=%v\n", col1)
 	}
-	rows.Close()
+
 	return rows.Err()
 }

examples/clickhouse_api/nested.go

@@ -20,8 +20,9 @@ package clickhouse_api
 import (
 	"context"
 	"fmt"
-	"github.com/ClickHouse/clickhouse-go/v2"
 	"strconv"
+
+	"github.com/ClickHouse/clickhouse-go/v2"
 )
 
 func NestedUnFlattened() error {
@@ -109,13 +110,15 @@ func NestedUnFlattened() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 		if err := rows.Scan(&col1, &col2); err != nil {
 			return err
 		}
 		fmt.Printf("row: col1=%v, col2=%v\n", col1, col2)
 	}
-	rows.Close()
+
 	return rows.Err()
 }
 

examples/clickhouse_api/progress.go

@@ -20,6 +20,7 @@ package clickhouse_api
 import (
 	"context"
 	"fmt"
+
 	"github.com/ClickHouse/clickhouse-go/v2"
 )
 
@@ -45,10 +46,11 @@ func ProgressProfileLogs() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 	}
 
 	fmt.Printf("Total Rows: %d\n", totalRows)
-	rows.Close()
 	return rows.Err()
 }

examples/std/external_data.go

@@ -63,6 +63,8 @@ func ExternalData() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 		var (
 			col1 uint8
@@ -72,7 +74,6 @@ func ExternalData() error {
 		rows.Scan(&col1, &col2, &col3)
 		fmt.Printf("col1=%d, col2=%s, col3=%v\n", col1, col2, col3)
 	}
-	rows.Close()
 
 	var count uint64
 	if err := conn.QueryRowContext(ctx, "SELECT COUNT(*) FROM external_table_1").Scan(&count); err != nil {

examples/std/open_db.go

@@ -94,6 +94,8 @@ func OpenDb() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 		var (
 			col1 uint8
@@ -105,6 +107,6 @@ func OpenDb() error {
 		}
 		fmt.Printf("row: col1=%d, col2=%s, col3=%s\n", col1, col2, col3)
 	}
-	rows.Close()
+
 	return rows.Err()
 }

examples/std/progress.go

@@ -20,6 +20,7 @@ package std
 import (
 	"context"
 	"fmt"
+
 	"github.com/ClickHouse/clickhouse-go/v2"
 )
 
@@ -45,10 +46,11 @@ func ProgressProfileLogs() error {
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	for rows.Next() {
 	}
 
 	fmt.Printf("Total Rows: %d\n", totalRows)
-	rows.Close()
 	return rows.Err()
 }