in xa/basic/select_for_update.go [28:42]
func selectForUpdateData(ctx context.Context) error {
sql := "select id, user_id from order_tbl where id=? for update"
ret, err := db.ExecContext(ctx, sql, 333)
if err != nil {
fmt.Printf("select for udpate failed, err:%v\n", err)
return err
}
rows, err := ret.RowsAffected()
if err != nil {
fmt.Printf("select for udpate failed, err:%v\n", err)
return err
}
fmt.Printf("select for udpate success: %d.\n", rows)
return nil
}