lhs 4 лет назад
Родитель
Сommit
1ea0a44c79
1 измененных файлов с 21 добавлено и 1 удалено
  1. 21 1
      repository/postgres/test.go

+ 21 - 1
repository/postgres/test.go

@@ -52,11 +52,12 @@ func (t Test) UserList1() (rs []interface{}, err error) {
 	println(string(data))
 	return
 }
-func (t Test) UserList() (rs []interface{}, err error) {
+func (t Test) UserList2() (rs []interface{}, err error) {
 	//var id int32
 	//var name string
 	//var ct time.Time
 	usone := UserListInfo{}
+
 	sql := `select id,name from func_userlist_query();`
 	_, err = t.writeDB().QueryFunc(t.ctx(), sql, []interface{}{}, []interface{}{&usone.Id, &usone.Name}, func(pgx.QueryFuncRow) error {
 
@@ -70,3 +71,22 @@ func (t Test) UserList() (rs []interface{}, err error) {
 	}
 	return
 }
+func (t Test) UserList() (rs []interface{}, err error) {
+	var id int
+	var name string
+	//var ct time.Time
+	//usone := UserListInfo{}
+
+	sql := `select id,name from func_userlist_query();`
+	_, err = t.writeDB().QueryFunc(t.ctx(), sql, []interface{}{}, []interface{}{&id, &name}, func(pgx.QueryFuncRow) error {
+		usone := UserListInfo{id, name}
+		fmt.Printf("%v\n", usone)
+		rs = append(rs, usone)
+
+		return nil
+	})
+	if err != nil {
+		fmt.Printf("QueryFunc error: %v", err)
+	}
+	return
+}