/* upload_fetch */
CALL ml_add_table_script( 'sync_mlintro_scriptversion', 'Product', 
    'upload_fetch',
    'SELECT name, quantity FROM Product WHERE name = {ml r.name}' );

/* upload_update */
CALL ml_add_table_script( 'sync_mlintro_scriptversion', 'Product',
    'upload_update',
    'UPDATE Product
        SET quantity = {ml r.quantity}, last_modified = now()
        WHERE name = {ml r.name}' );

/* upload_old_row_insert */
CALL ml_add_table_script( 'sync_mlintro_scriptversion', 'Product',
    'upload_old_row_insert',
    'INSERT INTO Product_old (name,quantity,last_modified)
        VALUES ({ml r.name}, {ml r.quantity}, now())');

/* upload_new_row_insert */
CALL ml_add_table_script( 'sync_mlintro_scriptversion', 'Product',
    'upload_new_row_insert',
    'INSERT INTO Product_new (name,quantity,last_modified)
        VALUES ({ml r.name}, {ml r.quantity}, now())');

/* upload_delete */
CALL ml_add_table_script( 'sync_mlintro_scriptversion', 'Product', 
    'upload_delete', '--{ml_ignore}');

/* resolve_conflict */
CALL ml_add_table_script( 'sync_mlintro_scriptversion', 'Product',
    'resolve_conflict',
    'DECLARE @product_name VARCHAR(128);
     DECLARE @old_rem_val INTEGER;
     DECLARE @new_rem_val INTEGER;
     DECLARE @curr_cons_val INTEGER; 
     DECLARE @resolved_value INTEGER;

     // obtain the product name
     SELECT name INTO @product_name FROM Product_old;

     // obtain the old remote value
     SELECT quantity INTO @old_rem_val FROM Product_old;

     //obtain the new remote value
     SELECT quantity INTO @new_rem_val FROM Product_new;

     // obtain the current value in cons
     SELECT quantity INTO @curr_cons_val FROM Product WHERE name = @product_name;

     // determine the resolved value
     SET @resolved_value = @curr_cons_val- (@old_rem_val - @new_rem_val);

     // update cons with the resolved value
     UPDATE Product
         SET quantity = @resolved_value
             WHERE name = @product_name;

    // clear the old and new row tables
    DELETE FROM Product_new;
    DELETE FROM Product_old');

COMMIT;