parent_ids_loc=None, next=None, col_defaults={}):

    db.autoanalyze = True # but don't do this in row-based import

    db.autoexplain = True # but don't do this in row-based import

    full_in_table = in_table

    total = 0

    while limit == None or total < limit:

        # Adjust partition size if last partition

        this_limit = partition_size

        if limit != None: this_limit = min(this_limit, limit - total)

        # Row # is interally 0-based, but 1-based to the user

        db.log_debug('********** Partition: rows '+str(start+1)+'-'

            +str(start+this_limit)+' **********', level=1.2)

        # Subset in_table

        in_table = copy.copy(full_in_table) # don't modify input!

        in_table.name = str(in_table) # prepend schema

        cur = sql.run_query_into(db, sql.mk_select(db, full_in_table,

            limit=this_limit, start=start), into=in_table, add_pkey_=True)

            # full_in_table will be shadowed (hidden) by created temp table

        this_ct = cur.rowcount

        total += this_ct

        start += this_ct # advance start to fetch next set

        if this_ct == 0: break # in_table size is multiple of partition_size

        # Recurse

        pkeys_loc = _put_table_part(db, node, in_table, row_ins_ct_ref,

            on_error, parent_ids_loc, next, col_defaults)

        if in_row_ct_ref != None: in_row_ct_ref[0] += this_ct

        sql.empty_temp(db, in_table)

        if this_ct < partition_size: break # partial partition = last

        # Work around PostgreSQL's temp table disk space leak

        db.reconnect()

    return pkeys_loc

def _put_table_part(db, node, in_table, row_ins_ct_ref, on_error,

    parent_ids_loc, next, col_defaults):

    '''Helper function for put_table() only; should not be called directly'''

    def put_table_(node, in_row_ct_ref=None):

        return _put_table_part(db, node, in_table, row_ins_ct_ref, on_error,

            parent_ids_loc, next, col_defaults)