func selectForUpdateData()

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
}