|
@@ -94,13 +94,16 @@ func (d *DB) Connect() (err error) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+/*
|
|
// Close close database connect
|
|
// Close close database connect
|
|
func (d *DB) Close() error {
|
|
func (d *DB) Close() error {
|
|
- if d.c != nil {
|
|
|
|
- return d.c.Close()
|
|
|
|
- }
|
|
|
|
|
|
+ // not use pool
|
|
|
|
+ if d.c != nil {
|
|
|
|
+ return d.c.Close()
|
|
|
|
+ }
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
|
|
+// */
|
|
|
|
|
|
// Ping verifies a connection to the database is still alive, establishing a connection if necessary.
|
|
// Ping verifies a connection to the database is still alive, establishing a connection if necessary.
|
|
func (d *DB) Ping() error {
|
|
func (d *DB) Ping() error {
|
|
@@ -193,7 +196,7 @@ func (d *DB) Get(dest interface{}, query string, args ...interface{}) (err error
|
|
if err != nil {
|
|
if err != nil {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- defer d.Close()
|
|
|
|
|
|
+ //defer d.Close()
|
|
|
|
|
|
err = d.c.Get(dest, query, args...)
|
|
err = d.c.Get(dest, query, args...)
|
|
return
|
|
return
|
|
@@ -205,7 +208,7 @@ func (d *DB) NamedGet(dest interface{}, query string, args interface{}) (err err
|
|
if err != nil {
|
|
if err != nil {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- defer d.Close()
|
|
|
|
|
|
+ //defer d.Close()
|
|
|
|
|
|
nstmt, err := d.c.PrepareNamed(query)
|
|
nstmt, err := d.c.PrepareNamed(query)
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -223,7 +226,7 @@ func (d *DB) Select(dest interface{}, query string, args ...interface{}) error {
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
- defer d.Close()
|
|
|
|
|
|
+ //defer d.Close()
|
|
|
|
|
|
err = d.c.Select(dest, query, args...)
|
|
err = d.c.Select(dest, query, args...)
|
|
return err
|
|
return err
|
|
@@ -235,7 +238,7 @@ func (d *DB) NamedSelect(dest interface{}, query string, args interface{}) (err
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
- defer d.Close()
|
|
|
|
|
|
+ //defer d.Close()
|
|
|
|
|
|
nstmt, err := d.c.PrepareNamed(query)
|
|
nstmt, err := d.c.PrepareNamed(query)
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -253,7 +256,7 @@ func (d *DB) Exec(query string, args ...interface{}) (LastInsertId, RowsAffected
|
|
if err != nil {
|
|
if err != nil {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- defer d.Close()
|
|
|
|
|
|
+ //defer d.Close()
|
|
|
|
|
|
var rs sql.Result
|
|
var rs sql.Result
|
|
rs, err = d.c.Exec(query, args...)
|
|
rs, err = d.c.Exec(query, args...)
|
|
@@ -272,7 +275,7 @@ func (d *DB) NamedExec(query string, args interface{}) (LastInsertId, RowsAffect
|
|
if err != nil {
|
|
if err != nil {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- defer d.Close()
|
|
|
|
|
|
+ //defer d.Close()
|
|
|
|
|
|
var rs sql.Result
|
|
var rs sql.Result
|
|
rs, err = d.c.NamedExec(query, args)
|
|
rs, err = d.c.NamedExec(query, args)
|
|
@@ -305,10 +308,12 @@ func PingContext(ctx context.Context) error {
|
|
return defaultDb.PingContext(ctx)
|
|
return defaultDb.PingContext(ctx)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+/*
|
|
// Close close database connect
|
|
// Close close database connect
|
|
func Close() error {
|
|
func Close() error {
|
|
return defaultDb.Close()
|
|
return defaultDb.Close()
|
|
}
|
|
}
|
|
|
|
+// */
|
|
|
|
|
|
// Stats returns database statistics.
|
|
// Stats returns database statistics.
|
|
func Stats() sql.DBStats {
|
|
func Stats() sql.DBStats {
|