登录
首页 >  Golang >  Go问答

SQL 集合没有结果行:在邮递员的 JSON 输入中发生错误结果

来源:stackoverflow

时间:2024-02-29 13:09:15 152浏览 收藏

golang学习网今天将给大家带来《SQL 集合没有结果行:在邮递员的 JSON 输入中发生错误结果》,感兴趣的朋友请继续看下去吧!以下内容将会涉及到等等知识点,如果你是正在学习Golang或者已经是大佬级别了,都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家!

问题内容

var (
    newServices                                                                                                             *models.UpsertIntoServices
    companyCode, serviceCode, approvalEmail, approvalName, coApprovalEmail, coApprovalName, technicianEmail, technicianName string
    departmentApproval, companyApproval, xapiensApproval, isActual, isMinus                                                 bool
    id                                                                                                                      uint
)

tx, txErr := s.db.Begin()
if txErr != nil {
    return newServices, txErr
}

qapi := `
insert into company_services 
    (company_code, service_code, department_approval, company_approval, xapiens_approval, approval_email, approval_name, co_approval_email,technician_email, co_approval_name, technician_name, is_actual, is_minus)
    values 
        ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13)
    on conflict (company_code, service_code)
do update set company_code =excluded.company_code, service_code =excluded.service_code;
`

//insert data into new_services
sqlErr := tx.QueryRowContext(ctx, qapi, data.CompanyCode, data.ServiceCode, data.DepartmentApproval, data.CompanyApproval, data.XapiensApproval, data.ApprovalEmail, data.ApprovalName, data.CoApprovalEmail, data.TechnicianEmail, data.CoApprovalName, data.TechnicianName, data.IsActual, data.IsMinus).Scan(
    &id,
    &companyCode,
    &serviceCode,
    &departmentApproval,
    &companyApproval,
    &xapiensApproval,
    &approvalEmail,
    &approvalName,
    &coApprovalEmail,
    &technicianEmail,
    &coApprovalName,
    &technicianName,
    &isActual,
    &isMinus,
)

// checking if its rows has any errors but no result here
if sqlErr != nil {
    tx.Rollback()
    log.Println("sql Error on Repository Upsert Flagging", sqlErr)
    return newServices, sqlErr
}

// commit transaction query
txErr = tx.Commit()
if txErr != nil {
    return newServices, txErr
}

正确答案


使用 execcontext 执行插入/更新查询。尝试下面的代码

var (
    newServices                                                                                                             *models.UpsertIntoServices
    companyCode, serviceCode, approvalEmail, approvalName, coApprovalEmail, coApprovalName, technicianEmail, technicianName string
    departmentApproval, companyApproval, xapiensApproval, isActual, isMinus                                                 bool
    id                                                                                                                      uint
)

tx, txErr := s.db.Begin()
if txErr != nil {
    return newServices, txErr
}

qapi := `
insert into company_services 
    (company_code, service_code, department_approval, company_approval, xapiens_approval, approval_email, approval_name, co_approval_email,technician_email, co_approval_name, technician_name, is_actual, is_minus)
    values 
        ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13)
    on conflict (company_code, service_code)
do update set company_code =excluded.company_code, service_code =excluded.service_code;
`

//insert data into new_services
result, sqlErr := tx.ExecContext(ctx, qapi, data.CompanyCode, data.ServiceCode, data.DepartmentApproval, data.CompanyApproval, data.XapiensApproval, data.ApprovalEmail, data.ApprovalName, data.CoApprovalEmail, data.TechnicianEmail, data.CoApprovalName, data.TechnicianName, data.IsActual, data.IsMinus)

// checking if its rows has any errors but no result here
if sqlErr != nil {
    tx.Rollback()
    log.Println("sql Error on Repository Upsert Flagging", sqlErr)
    return newServices, sqlErr
}
//You can know lastInsertId and affectedRows
lastInsertId, _ := result.LastInsertId()
affectedRowsCnt,_ :=  result.RowsAffected()
fmt.Println(lastInsertId,affectedRowsCnt)

// commit transaction query
txErr = tx.Commit()
if txErr != nil {
    return newServices, txErr
}

文中关于的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《SQL 集合没有结果行:在邮递员的 JSON 输入中发生错误结果》文章吧,也可关注golang学习网公众号了解相关技术文章。

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>