Выберите и получите использование с sqlx - PullRequest
Новая
       23

Выберите и получите использование с sqlx

0 голосов
/ 25 августа 2018

Я использую go 1.10.3 и пытаюсь использовать пакет sqlx, чтобы получить одну строку и ввести ее в структуру с помощью Get(), или получить несколько строк и ввести их в срез с помощью Select() .

Давайте начнем с получения одной строки в структуре.

Я создал следующую структуру: 

type PsqlProduct struct {
    Id              int64          `db:"product_id"`
    Name            string         `db:"product_name"`
    Desc            sql.NullString `db:"product_desc"`
    YearManufacture sql.NullInt64  `db:"year_manufacture"`
    Quantity        sql.NullInt64  `db:"quantity"`
}

для запроса: 

QUERY_SELECT_PRODUCT = `select wd.product.id as product_id,
trans_p_name.text as product_name,
trans_p_desc.text as product_desc,
wd.product.year_manufacture, wd.product.quantity
from wd.product
join wd.text_translation as trans_p_name 
    on trans_p_name.text_id = wd.product.product_name_trans_id and trans_p_name.lang_id=1
left join wd.text_translation as trans_p_desc 
    on trans_p_desc.text_id = wd.product.product_desc_trans_id and trans_p_desc.lang_id=1
where wd.product.id = $1 
`

и я создал следующую функцию для получения товара по идентификатору: 

func PsqlGetProductById(productId int) *Product {
    product := new(PsqlProduct)
    err := Psqldb.Get(&product, QUERY_SELECT_PRODUCT,productId)
    if err != nil {
        log.Fatalf("error: %v",err)
        return nil
    } else {

        newp := Product{
            ID:   uint(product.Id),
            Name: product.Name,
        }
        if product.Quantity.Valid {
            newp.Quantity = uint16(product.Quantity.Int64)
        }
        if product.YearManufacture.Valid {
            newp.YearManufacture = uint16(product.YearManufacture.Int64)
        }
        if product.Desc.Valid {
            newp.Desc = product.Desc.String
        }
        return &newp
    }
}

и я получил ошибку 

error: scannable dest type ptr with >1 columns (5) in result

это как если бы Get() функция была только для одного столбца .. но в документации ясно сказано, что это не так!

если я изменю вызов функции Get() на Psqldb.QueryRowx(QUERY_SELECT_PRODUCT, productId).StructScan(product)

тогда это работает ... но все же .. пытаясь выяснить, почему Get() не работает.

следующий .. Select()

так что это структура 

type PsqlCategory struct {
    Id               int64         `db:"category_id"`
    Name             string        `db:"category_name"`
    ParentCategoryId sql.NullInt64 `db:"parent_category_id"`
}

sql запрос: 

QUERY_SELECT_CATEGORIES = `
select category.id as category_id,
       text_translation.text as category_name,
       category.parent_category_id
from category
join text_translation on text_translation.text_id=category.category_name_trans_id
and text_translation.lang_id = 1`

и функция 

func PsqlGetCategories() []Category {
    categories := []PsqlCategory{}
    err := Psqldb.Select(&categories, QUERY_SELECT_CATEGORIES)
    if err != nil {
        log.Fatalf("could not parse categories: %v", err)
        return nil
    }
    var nCategories []Category
    for _, cat := range categories {
        newCat := Category{
            Id:   cat.Id,
            Name: cat.Name,
        }
        if cat.ParentCategoryId.Valid {
            newCat.ParentCategoryId = cat.ParentCategoryId.Int64
        }
        nCategories = append(nCategories, newCat)
    }
    return nCategories
}

и это ошибка 

could not parse categories: pq: relation "category" does not exist

похоже, что я полностью неправильно понял использование библиотеки sqlx или я что-то упустил ..

любая информация по этому вопросу будет принята с благодарностью.

1 Ответ

0 голосов
/ 25 августа 2018

Проблема возникает из-за того, что вы передаете **PsqlProduct в Get, который думает, что вы хотите отсканировать результат запроса в указатель на указатель, следовательно "... dest type ptr with >1 columns ...".

Просто измените: 

err := Psqldb.Get(&product, QUERY_SELECT_PRODUCT,productId)

до: 

err := Psqldb.Get(product, QUERY_SELECT_PRODUCT,productId)
...