db Package

db Package

class okcupyd.db.Query(entities, session=None)

Bases: sqlalchemy.orm.query.Query

class okcupyd.db.txn(session_class=None)

Bases: object

okcupyd.db.with_txn(function, instance, args, kwargs)

class okcupyd.db.OKCBase(**kwargs)

Bases: sqlalchemy.ext.declarative.api.Base

okc_id = Column(None, StringBackedInteger(), table=None, nullable=False)

okcupyd.db.reset_engine(engine)

okcupyd.db.set_sqlite_db_file(file_path)

adapters Module

class okcupyd.db.adapters.UserAdapter(profile)

Bases: object

build(session)

get_no_txn(session)

get(session)

class okcupyd.db.adapters.ThreadAdapter(thread)

Bases: object

add_messages()

get_thread()

mailbox Module

class okcupyd.db.mailbox.Sync(user)

Bases: object

Sync messages from a users inbox to the okc database.

all()

update_mailbox

Update the mailbox associated with the given mailbox name.

inbox

Update the mailbox associated with the given mailbox name.

outbox

Update the mailbox associated with the given mailbox name.

types Module

class okcupyd.db.types.JSONType(*args, **kwargs)

Bases: sqlalchemy.sql.type_api.TypeDecorator

impl

alias of VARCHAR

process_bind_param(value, dialect)

process_result_value(value, dialect)

class okcupyd.db.types.StringBackedInteger(*args, **kwargs)

Bases: sqlalchemy.sql.type_api.TypeDecorator

impl

alias of VARCHAR

process_bind_param(value, dialect)

process_result_value(value, dialect)

user Module

okcupyd.db.user.have_messaged_by_username_no_txn(session, username_one, username_two)

okcupyd.db.user.have_messaged_by_username(session, username_one, username_two)

Subpackages

• model Package
  • model Package
  • message Module
  • message_thread Module
  • user Module