use db.QueryRow

Author: ungerik

examples/user_demo/user_demo.go

@@ -145,7 +145,7 @@ func main() {
 
 	db.SetConn(conn)
 
-	err = db.Conn(ctx).Exec("...")
+	err = db.Exec(ctx, "...")
 	if err != nil {
 		panic(err)
 	}
@@ -158,17 +158,17 @@ func main() {
 			return err
 		}
 		if user == nil {
-			return db.Conn(ctx).Exec("...")
+			return db.Exec(ctx, "...")
 		}
-		return db.Conn(ctx).Exec("...")
+		return db.Exec(ctx, "...")
 	})
 	if err != nil {
 		panic(err)
 	}
 }
 
 func GetUserOrNil(ctx context.Context, userID uu.ID) (user *User, err error) {
-	err = db.Conn(ctx).QueryRow(
+	err = db.QueryRow(ctx,
 		`select * from public.user where id = $1`,
 		userID,
 	).ScanStruct(&user)

information/column.go

@@ -76,7 +76,7 @@ func ColumnExists(ctx context.Context, table, column string) (exists bool, err e
 		tableName = table
 	}
 
-	err = db.Conn(ctx).QueryRow(
+	err = db.QueryRow(ctx,
 		`select exists(
 			select from information_schema.columns
 			where table_schema = $1

information/primarykeys.go

@@ -27,7 +27,7 @@ type PrimaryKeyColumn struct {
 func GetPrimaryKeyColumns(ctx context.Context) (cols []PrimaryKeyColumn, err error) {
 	defer errs.WrapWithFuncParams(&err, ctx)
 
-	err = db.Conn(ctx).QueryRows(`
+	err = db.QueryRows(ctx, `
 		select
 			tc.table_schema||'.'||tc.table_name as "table",
 			kc.column_name                      as "column",
@@ -67,7 +67,7 @@ func GetPrimaryKeyColumns(ctx context.Context) (cols []PrimaryKeyColumn, err err
 func GetPrimaryKeyColumnsOfType(ctx context.Context, pkType string) (cols []PrimaryKeyColumn, err error) {
 	defer errs.WrapWithFuncParams(&err, ctx, pkType)
 
-	err = db.Conn(ctx).QueryRows(`
+	err = db.QueryRows(ctx, `
 		select
 			tc.table_schema||'.'||tc.table_name as "table",
 			kc.column_name                      as "column",

information/table.go

@@ -22,7 +22,7 @@ type Table struct {
 }
 
 func GetTable(ctx context.Context, catalog, schema, name string) (table *Table, err error) {
-	err = db.Conn(ctx).QueryRow(
+	err = db.QueryRow(ctx,
 		`select *
 			from information_schema.tables
 			where table_catalog = $1
@@ -39,7 +39,7 @@ func GetTable(ctx context.Context, catalog, schema, name string) (table *Table,
 }
 
 func GetAllTables(ctx context.Context) (tables []*Table, err error) {
-	err = db.Conn(ctx).QueryRows(
+	err = db.QueryRows(ctx,
 		`select * from information_schema.tables`,
 	).ScanStructSlice(&tables)
 	if err != nil {