def __init__(self, conn: DBConn, table, schema, ntRec: namedtuple):
    self.conn = conn
    self.table = table
    self.schema = schema
    self.ntRec = ntRec
    self.pk_fields = None
    self.table_obj = (((schema + '.') + table) if schema else table)
    self.insert_one = (lambda row: self.insert([row]))
    self.add = (lambda **kws: self.insert([self.ntRec(**kws)]))
    self.update_one = (lambda row, pk_cols=None: self.update([row], pk_cols))
    self.update_rec = (lambda pk_cols=None, **kws: self.update([make_rec(**kws)], pk_cols))
    self.replace_one = (lambda row, pk_cols=None: self.replace([row], pk_cols))
    self.replace_rec = (lambda pk_cols=None, **kws: self.replace([make_rec(**kws)], pk_cols))
def __init__(self, conn: DBConn, table, schema, ntRec: namedtuple):
    self.conn = conn
    self.table = table
    self.schema = schema
    self.ntRec = ntRec
    self.pk_fields = None
    self.table_obj = (((schema + '.') + table) if schema else table)
    self.insert_one = (lambda row: self.insert([row]))
    self.add = (lambda **kws: self.insert([self.ntRec(**kws)]))
    self.update_one = (lambda row, pk_cols=None: self.update([row], pk_cols))
    self.update_rec = (lambda pk_cols=None, **kws: self.update([make_rec(**kws)], pk_cols))
    self.replace_one = (lambda row, pk_cols=None: self.replace([row], pk_cols))
    self.replace_rec = (lambda pk_cols=None, **kws: self.replace([make_rec(**kws)], pk_cols))