多行.Next() 在同一时间 golang sql/database

Question

我正在开发一个吸引用户的功能。我的问题是我必须将两个查询的结果作为rows.Next() 和rows1.Next() 中的一个结果返回，例如user_id、subject、phone。

这是我所拥有的，但它不起作用。你能帮我提些建议吗：

func GetUsers() (users []Users, err error) {

    users = make([]Users, 0)
    rows, err := db1.Query("SELECT  user_id, subject,phone FROM users limit 11")
    rows1, err := db1.Query("Select body from users limit 11")
    defer rows.Close()
    if err != nil {
        // handle this error better than this
        log.Fatal(err)
        //return
    }
    var user Users
    for rows.Next() {
        rows.Scan(&user.ID, &user.Subject, &user.Phone)
        users = append(users, user)
    }
    for rows1.Next() {

        rows1.Scan(&user.Body)
        users = append(users, user)

    }
    return 
}

我有一个名为users 的表，它基本上没有主键：

user_id . name  . body 
-----------------------
1       . model . 2
1       . brand . 1
1       . fuel  . 3
1       . date  . 1
1       . year  . 1

我必须有结果：

userid . model . brand . fuel . date . year 
1      . 2     . 1     . 3    . 1    . 1

所以列名中的值将是行。我已经定义了包含所有需要的字段的结构。

Answer 1

查看示例代码很明显，您应该在一个查询而不是两个查询中执行您正在执行的任何操作。即使您的实际代码稍有不同，假设您需要查询多个表，您仍然应该使用 JOIN 只执行一个查询。

users := make([]*User, 0)
rows, err := db1.Query("SELECT  user_id, subject,phone, body FROM users limit 11")
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

for rows.Next() {
    user := new(User)
    if err := rows.Scan(&user.ID, &user.Subject, &user.Phone, &user.Body); err != nil {
        panic(err)
    }       
    users = append(users, user)
}
if err := rows.Err(); err != nil {
    panic(err)
}

也就是说，如果您想按照您在问题中说明的方式进行操作，您可以这样做。

（这可能不是你应该做的）

users := make([]*User, 0)
rows, err := db1.Query("SELECT  user_id, subject,phone FROM users limit 11")
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

rows1, err := db1.Query("Select body from users limit 11")
if err != nil {
    panic(err)
}
defer rows1.Close()

for rows.Next() {
    user := new(User)
    if err := rows.Scan(&user.ID, &user.Subject, &user.Phone); err != nil {
        panic(err)
    }
    if !rows1.Next() {
        panic("no next body row")
    }
    if err := rows1.Scan(&user.Body); err != nil {
        panic(err)
    }

    users = append(users, user)
}
if err := rows.Err(); err != nil {
    panic(err)
}
if err := rows1.Err(); err != nil {
    panic(err)
}

Answer 2

const maxPerPage = 100

type Scanable interface {
    GetScans() []interface{}
}

type User struct {
    ID      int
    Subject string
    Phone   string
    Body    string
}

func (s *User) GetScans() []interface{} {
    return []interface{}{&s.ID, &s.Subject, &s.Phone, &s.Body}
}

func getNewUserList() []*User {
    users := make([]*User, maxPerPage)
    for i := 0; i < maxPerPage; i++ {
        users[i] = new(User)
    }
    return users
}

var usersPool = sync.Pool{
    New: func() interface{} {
        return getNewUserList()
    },
}

func getUsers() (b []*User) {
    ifc := usersPool.Get()
    if ifc != nil {
        b = ifc.([]*User)
    } else {
        b = getNewUserList()
    }
    return
}

func putUsers(b []*User) {
    // if cap(b) <= maxPerPage {
    //     b = b[:0] // reset
    //     usersPool.Put(&b)
    // }
    usersPool.Put(&b)
}

func TestUsers(t *testing.T) {

    users := getUsers()

    rows, err := PostgresConnection.Query("SELECT user_id, subject,phone, body FROM users limit 11")
    if err != nil {
        log.Fatal(err)
    }
    defer rows.Close()

    length := 0
    for rows.Next() {
        if err := rows.Scan(users[i].GetScans()...); err != nil {
                panic(err)
            }
            if err := rows.Err(); err != nil {
                panic(err)
            }
        length++
    }

    result := users[:length]
    fmt.Println(result)

    putUsers(users)
}