Browse Source

update db default method

ls 2 năm trước cách đây
mục cha
commit
ae201df0c9
1 tập tin đã thay đổi với 34 bổ sung0 xóa
  1. 34 0
      db/db.go

+ 34 - 0
db/db.go

@@ -346,6 +346,23 @@ func Select(dest interface{}, query string, args ...interface{}) (err error) {
 	return
 }
 
+// Rows get rows
+func Rows(dest interface{}, query string, args interface{}) (err error) {
+	defaultDB.conn, err = connect()
+	if err != nil {
+		return err
+	}
+
+	nstmt, err := defaultDB.conn.PrepareNamed(query)
+	if err != nil {
+		return
+	}
+	defer nstmt.Close()
+
+	err = nstmt.Select(dest, args)
+	return
+}
+
 // Get get
 func Get(dest interface{}, query string, args ...interface{}) (err error) {
 	defaultDB.conn, err = connect()
@@ -356,3 +373,20 @@ func Get(dest interface{}, query string, args ...interface{}) (err error) {
 	err = defaultDB.conn.Get(dest, query, args...)
 	return
 }
+
+// Row get row
+func Row(dest interface{}, query string, args interface{}) (err error) {
+	defaultDB.conn, err = connect()
+	if err != nil {
+		return
+	}
+
+	nstmt, err := defaultDB.conn.PrepareNamed(query)
+	if err != nil {
+		return err
+	}
+	defer nstmt.Close()
+
+	err = nstmt.Get(dest, args)
+	return
+}