Browse Source

db trans row

ls 3 years ago
parent
commit
c93e4ef37e
1 changed files with 8 additions and 1 deletions
  1. 8 1
      db/db.go

+ 8 - 1
db/db.go

@@ -150,7 +150,14 @@ func (d *DB) TransUpdate(query string, args interface{}) (reply Reply) {
 
 // TransRow trans get row
 func (d *DB) TransRow(dest interface{}, query string, args interface{}) error {
-	err = d.tx.Get(dest, query, args)
+	nstmt, err := d.tx.PrepareNamed(query)
+	if err != nil {
+		return err
+	}
+	defer nstmt.Close()
+
+	err = nstmt.Get(dest, args)
+	//err = d.tx.Get(dest, query, args)
 	return err
 }