Циклический результат из запроса выбора SQL - PullRequest
0 голосов
/ 25 октября 2018

Итак, я изучаю Go - Language atm, и я все еще не могу понять, как итерировать массив, который я получаю из SQL при выполнении моего запроса

здесь для подробностей

Я получилфайл с именем CustomerDao.go , который содержит несколько запросов, и теперь я использую запрос

SELECT mst_customer.mcus_mlok_pk , mst_customer.mcus_mlok_kode , mst_customer.mcus_nama FROM frontend.mst_customer;

, который вернет 50 строк данных и 3 столбца, да?Теперь сбивает с толку часть, когда я достигаю свой контроллер, подобный этому

func GetArrayListCustomer(queryType string) (map[string]CustomerModelResponse, error) {
    logger := customlogger.GetInstance()
    logger.Println("Service: GetArrayListCustomer Start")

    queryText := dao.CustomerDAO(queryType)
    res, err := config.GetDbByPath("myDatabase").GetDb().Query(queryText)

    mapList := make(map[string]CustomerModelResponse)
    var custResponse CustomerModelResponse

    if config.FancyHandleError(err) {
        logger.Println("Service: GetArrayListCustomer -> Error " + err.Error())
        return mapList, err
    }
    defer res.Close()
    for res.Next() {
        errs := res.Scan(&custResponse.McusmlokPk, &custResponse.McusmlokKode, &custResponse.McusNama)
        for _, eachCust := range res {
            //the error goes here , for some reason
        }
    }
    return mapList, nil
}

, и затем я пытаюсь зациклить значение, тогда ошибка показывает, что я не могу выбрать диапазон по res, который является * sql.Rows Как сделатьЯ объявляю эти результаты в виде массива, а не типа * sql.Rows?

Ответы [ 2 ]

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

Вам нужно отсканировать свои значения в структуру, используя rows.Next, вы перебираете результаты SQL, которые дает ваш запрос, вам нужно отсканировать эти результаты (в каждом цикле) в нужную структуру и сохранить эту структуру во что-то (карта в данном случае)

func GetArrayListCustomer(queryType string) (map[string]CustomerModelResponse, error) {
    logger := customlogger.GetInstance()
    logger.Println("Service: GetArrayListCustomer Start")

    queryText := dao.CustomerDAO(queryType)
    res, err := config.GetDbByPath("myDatabase").GetDb().Query(queryText)

    mapList := make(map[string]CustomerModelResponse)

    if config.FancyHandleError(err) {
        logger.Println("Service: GetArrayListCustomer -> Error " + err.Error())
        return mapList, err
    }
    defer res.Close()
    for res.Next() {
        var custResponse CustomerModelResponse
        if err := res.Scan(&custResponse.McusmlokPk, &custResponse.McusmlokKode, &custResponse.McusNama); err != nil {
            // Handle error
        }
        mapList[cutResponse.McusmlokPk] = custResponse
    }
    // Now mapList is a map with McusmlokPk as key and CustomerModelResponse struct as value
    return mapList, nil
}
0 голосов
/ 25 октября 2018

Вы не можете использовать цикл for range на res.res может быть повторен только с использованием Next().Вот что вы можете сделать:

for res.Next() {

    //CREATE A NEW ZERO VALUE CustomerModelResponse FOR EACH ITERATION
    var custResponse CustomerModelResponse

    // UPDATE CustomerModelResponse WITH ROW DATA
    errs := res.Scan(&custResponse.McusmlokPk, &custResponse.McusmlokKode, &custResponse.McusNama)

    if errs == nil {
        // APPEND THE NEWLY CREATED & UPDATED CustomerModelResponse TO mapList
        // ASSUMINg mst_customer.mcus_mlok_pk AS KEY FOR THE MAP

        mapList[custResponse.McusmlokPk] = custResponse
    }

    /*
        THIS LOOP IS NOT NEEDED ANY MORE

        for _, eachCust := range res {
            //the error goes here , for some reason
        }
    */
}

Надеюсь, это поможет.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...