func insertOnUpdateDataFail()

in at/rollback/server2/insert_on_update.go [26:43]


func insertOnUpdateDataFail(ctx context.Context) error {
	// generate an err : insert on update sql requires primary key insert column
	sql := "insert into order_tbl (user_id, commodity_code, count, money, descs) values (?, ?, ?, ?, ?) " +
		"on duplicate key update descs=?"
	ret, err := db.ExecContext(ctx, sql, "NO-100001", "C100000", 100, nil, "init desc", fmt.Sprintf("insert on update descs %d", time.Now().Unix()))
	if err != nil {
		fmt.Printf("update failed, err:%v\n", err)
		return nil
	}

	rows, err := ret.RowsAffected()
	if err != nil {
		fmt.Printf("update failed, err:%v\n", err)
		return nil
	}
	fmt.Printf("update success: %d.\n", rows)
	return nil
}