Function fetch_record

24-class-metaprog/persistent/dblib.py:130–140

(table_name: str, pk: int)

def fetch_record(table_name: str, pk: int) -> sqlite3.Row:
    check_identifier(table_name)
    con = get_connection()
    sql = f'SELECT * FROM {table_name} WHERE pk = ? LIMIT 2'
    result = list(con.execute(sql, (pk,)))
    if len(result) == 0:
        raise NoSuchRecord(pk)
    elif len(result) == 1:
        return result[0]
    else:
        raise UnexpectedMultipleResults()


def update_record(