Как левое соединение работает с sqlx - PullRequest
Новая
       28

Как левое соединение работает с sqlx

0 голосов
/ 03 октября 2018

Я пытаюсь внутренне объединить две таблицы person и profile с помощью простого запроса, который, кажется, работает нормально с mysql, но не с sqlx.Вот мой код go: 

package main 

import (
    "fmt"
    "github.com/jmoiron/sqlx"
    _ "github.com/go-sql-driver/mysql"
)

type Person struct {
    Id      int64   `db:"id"`
    Name    string  `db:"name"`
    Email   string  `db:"email"`
}

type Profile struct {
    Id          int64   `db:"id"`
    Face        string  `db:"face"`
    Hair        string  `db:"hair"`
    Person
}

func main() {
    DB, err := sqlx.Connect("mysql", "root:hackinitiator@/dusk")
    if err == nil {
        fmt.Println("sucess!!")
    } 
    var q []Profile
    DB.Select(&q, "select person.id, person.name, person.email, profile.id, profile.face, profile.hair from profile left join person on person.id = profile.person_id")
    fmt.Println(q)
}

Запрос mysql выдает следующий вывод: 

+------+------+---------+----+----------+--------+
| id   | name | email   | id | face     | hair   |
+------+------+---------+----+----------+--------+
|    1 | yoda | nomail  |  1 | round    | brown  |
|    5 | han  | nomail1 |  3 | circle   | red    |
|    6 | yun  | nomail2 |  4 | triangle | yellow |
|    7 | chi  | nomail3 |  5 | square   | green  |
+------+------+---------+----+----------+--------+

, что совершенно нормально, но моя программа go не отвечает, как ожидалось.Структура не может захватить идентификатор профиля (пустой на выходе), а идентификатор человека заменяется идентификатором профиля.Ниже приведен вывод (в формате): 

[
{0 round brown {1 yoda nomail}} 
{0 circle red {3 han nomail1}} 
{0 triangle yellow {4 yun nomail2}} 
{0 square green {5 chi nomail3}}
]

Я не могу понять, что пошло не так.

Ответы [ 3 ]

0 голосов
/ 03 октября 2018

Ошибка связана с возвращением двух id столбцов из результата, но сохранением результата в структуре с одинаковым идентификатором имени поля в обеих структурах, экземпляр которых вы передаете в DB.Select.Попробуйте захватить один столбец id и передать его в struct.

Передать несколько столбцов, но имя другого столбца можно использовать в качестве псевдонима.Псевдонимом столбца будет поле в структуре Person, в котором вы сканируете данные как: 

type Person struct {
    PersonId    int64   `db:"personId"`
    Name        string  `db:"name"`
    Email       string  `db:"email"`
}

var q []Profile
DB.Select(&q, "select person.id as personId, person.name, person.email, profile.id, profile.face, profile.hair from profile left join person on person.id = profile.person_id")
fmt.Println(q)
0 голосов
/ 04 октября 2018

Следуя фрагменту, предоставленному @ zerkms Я внес несколько изменений, которые позволили мне запустить программу без ошибок и без переименования тегов db.Сначала я добавил приведенный ниже код в структуру профиля, чтобы запрос идентифицировал структуру лица 

Person `db:"person"`

. После этого я изменил строку запроса SQL на приведенный ниже код 

DB.Select(&q, `select person.id "person.id", person.name "person.name", person.email "person.email", profile.* from profile left join person on person.id = profile.person_id`)

, чтобы избежать дублирования.имена столбцов, указанные @ zerkms

0 голосов
/ 03 октября 2018

Вам нужно изменить db имя в person struct, как показано ниже. Я описываю, потому что будет два столбца с одинаковым именем, т.е. id, поэтому он сканирует только последний идентификатор, который находится в вашей таблице profileа не сканирование таблицы person, поэтому следуйте структуре, как указано ниже. 

type Person struct {
    Id      int64   `db:"pId"`
    Name    string  `db:"name"`
    Email   string  `db:"email"`
}

И затем напишите свой запрос с as для person.id, как 

DB.Select(&q, "select (person.id) as pId, person.name, person.email, profile.id, profile.face, profile.hair from profile left join person on person.id = profile.person_id")
...