2021年12月15日 09:58:30go评论81阅读模式

英文:

Error SQL NO result rows in set. when i input from postman with json it has error result in a rows

问题

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(
	&amp;id,
	&amp;companyCode,
	&amp;serviceCode,
	&amp;departmentApproval,
	&amp;companyApproval,
	&amp;xapiensApproval,
	&amp;approvalEmail,
	&amp;approvalName,
	&amp;coApprovalEmail,
	&amp;technicianEmail,
	&amp;coApprovalName,
	&amp;technicianName,
	&amp;isActual,
	&amp;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
}

这是一段Go代码，它包含了一些变量声明和数据库操作。代码的主要功能是将数据插入到数据库表company_services中，并在冲突时执行更新操作。具体步骤如下：

开始数据库事务。
准备SQL语句qapi，用于插入数据或执行更新操作。
使用tx.QueryRowContext方法执行SQL语句，并将结果扫描到相应的变量中。
检查是否有SQL错误，如果有则回滚事务并返回错误。
提交事务。
返回结果或错误。

请注意，这段代码中的变量和数据是根据上下文提供的，因此无法确定具体的值和类型。

英文:

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(
	&amp;id,
	&amp;companyCode,
	&amp;serviceCode,
	&amp;departmentApproval,
	&amp;companyApproval,
	&amp;xapiensApproval,
	&amp;approvalEmail,
	&amp;approvalName,
	&amp;coApprovalEmail,
	&amp;technicianEmail,
	&amp;coApprovalName,
	&amp;technicianName,
	&amp;isActual,
	&amp;isMinus,
)

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

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

答案1

得分: 0

使用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
}

请注意，这只是代码的翻译部分，不包括任何其他内容。

英文:

Use ExecContext to execute insert/update query. Try the below code

 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(&quot;sql Error on Repository Upsert Flagging&quot;, 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结果集中没有行。当我使用Postman输入JSON时，出现了错误结果行。

问题

答案1

均匀分布与朴素洗牌？

在for循环中的goroutine只会获取切片的最后一个值。

为什么 goroutine 在 for 循环结束之前不执行？

golang UDP服务器的奇怪行为

What's the correct way to type hint an empty list as a literal in python?

如何在Highcharts Gantt中更改本地化的星期名称

如何在同一个流中使用多个过滤器和映射函数？

如何使用Map/Set来将代码优化到O(n)？

.NET MAUI Android在GitHub Actions上构建失败，错误代码为1。

如何在Playwright视觉比较中屏蔽多个定位器？

在C++中，可以使用可变模板参数来检索类型的内部类型。

selenium.common.exceptions.StaleElementReferenceException: Message: stale element reference: stale element not found

Creating and opening a URL to log in to Website via Basic Auth with Robot Framework/Selenium (Python)

AG Grid 在上下文菜单中以大文本形式打开

发表评论