@@ -31,7 +31,7 @@ type Postgres struct {
31
31
// New postgres adapter using existing connection.
32
32
func New (database * db.DB ) rel.Adapter {
33
33
var (
34
- bufferFactory = builder.BufferFactory {ArgumentPlaceholder : "$" , ArgumentOrdinal : true , BoolTrueValue : "true" , BoolFalseValue : "false" , Quoter : Quote {}, ValueConverter : ValueConvert {}}
34
+ bufferFactory = builder.BufferFactory {TablePartsSeparator : "." , ArgumentPlaceholder : "$" , ArgumentOrdinal : true , BoolTrueValue : "true" , BoolFalseValue : "false" , Quoter : Quote {}, ValueConverter : ValueConvert {}}
35
35
filterBuilder = builder.Filter {}
36
36
queryBuilder = builder.Query {BufferFactory : bufferFactory , Filter : filterBuilder }
37
37
OnConflictBuilder = builder.OnConflict {Statement : "ON CONFLICT" , IgnoreStatement : "DO NOTHING" , UpdateStatement : "DO UPDATE SET" , TableQualifier : "excluded" , SupportKey : true }
@@ -62,13 +62,13 @@ func New(database *db.DB) rel.Adapter {
62
62
63
63
// Open postgres connection using dsn.
64
64
func Open (dsn string ) (rel.Adapter , error ) {
65
- var database , err = db .Open ("postgres" , dsn )
65
+ database , err : = db .Open ("postgres" , dsn )
66
66
return New (database ), err
67
67
}
68
68
69
69
// MustOpen postgres connection using dsn.
70
70
func MustOpen (dsn string ) rel.Adapter {
71
- var database , err = db .Open ("postgres" , dsn )
71
+ database , err : = db .Open ("postgres" , dsn )
72
72
check (err )
73
73
return New (database )
74
74
}
@@ -111,9 +111,7 @@ func (p Postgres) InsertAll(ctx context.Context, query rel.Query, primaryField s
111
111
112
112
// Begin begins a new transaction.
113
113
func (p Postgres ) Begin (ctx context.Context ) (rel.Adapter , error ) {
114
- var (
115
- txSql , err = p .SQL .Begin (ctx )
116
- )
114
+ txSql , err := p .SQL .Begin (ctx )
117
115
118
116
return & Postgres {SQL : * txSql .(* sql.SQL )}, err
119
117
}
0 commit comments