run_query(db, function_query, cacheable=True)

        # Return query that uses function

    return (query, params)

        if not create: raise

        return put(db, table, row, pkey, row_ct_ref) # insert new row

    '''Recovers from errors.

    Only works under PostgreSQL (uses INSERT RETURNING).

    @param in_tables The main input table to select from, followed by a list of

    joins = [in_tables0] + [(t, {in_pkey: join_using}) for t in in_tables]

    def mk_select_(cols):

    out_pkeys = out_table_clean+'_out_pkeys'

    def insert_():

        # Join together out_pkeys and in_pkeys

        run_query_into(db, *mk_select(db,

            [in_pkeys, (out_pkeys, {row_num_col: join_using})],

    try:

        # Insert and capture output pkeys

    # Insert node

    pkeys_loc = sql.put_table(db, esc_name(out_table), in_tables, row,

    if commit: db.db.commit()

    return pkeys_loc