FM / playhouse

/opt/alt/python38/lib64/python3.8/site-packages/playhouse/

/opt/alt/python38/lib64/python3.8/site-packages/playhouse

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
apsw_ext.py	5061	0644	edit dl rm
berkeleydb.py	4138	0644	edit dl rm
csv_loader.py	75	0644	edit dl rm
csv_utils.py	11608	0644	edit dl rm
dataset.py	10993	0644	edit dl rm
db_url.py	3893	0644	edit dl rm
djpeewee.py	7904	0644	edit dl rm
fields.py	11806	0644	edit dl rm
flask_utils.py	5663	0644	edit dl rm
gfk.py	6035	0644	edit dl rm
hybrid.py	1473	0644	edit dl rm
kv.py	4807	0644	edit dl rm
migrate.py	24057	0644	edit dl rm
pool.py	8201	0644	edit dl rm
postgres_ext.py	13448	0644	edit dl rm
read_slave.py	1449	0644	edit dl rm
reflection.py	21845	0644	edit dl rm
shortcuts.py	7203	0644	edit dl rm
signals.py	2249	0644	edit dl rm
sqlcipher_ext.py	4222	0644	edit dl rm
sqliteq.py	8539	0644	edit dl rm
sqlite_ext.py	35778	0644	edit dl rm
sqlite_udf.py	13576	0644	edit dl rm
test_utils.py	2799	0644	edit dl rm
_speedups.cpython-38-x86_64-linux-gnu.so	244264	0755	edit dl rm
_sqlite_ext.cpython-38-x86_64-linux-gnu.so	73688	0755	edit dl rm
_sqlite_udf.cpython-38-x86_64-linux-gnu.so	89768	0755	edit dl rm
__init__.py	0	0644	edit dl rm

Edit: /opt/alt/python38/lib64/python3.8/site-packages/playhouse/read_slave.py (1449B)

"""
Support for using a dedicated read-slave. The read database is specified as a
Model.Meta option, and will be used for SELECT statements:

master = PostgresqlDatabase('master')
read_slave = PostgresqlDatabase('read_slave')

class BaseModel(ReadSlaveModel):
    class Meta:
        database = master
        read_slaves = [read_slave]  # This database will be used for SELECTs.

# Now define your models as you would normally.
class User(BaseModel):
    username = CharField()

# To force a SELECT on the master database, you can instantiate the SelectQuery
# by hand:
master_select = SelectQuery(User).where(...)
"""
from peewee import *

class ReadSlaveModel(Model):
    @classmethod
    def _get_read_database(cls):
        if not getattr(cls._meta, 'read_slaves', None):
            return cls._meta.database
        current_idx = getattr(cls, '_read_slave_idx', -1)
        cls._read_slave_idx = (current_idx + 1) % len(cls._meta.read_slaves)
        return cls._meta.read_slaves[cls._read_slave_idx]

@classmethod
    def select(cls, *args, **kwargs):
        query = super(ReadSlaveModel, cls).select(*args, **kwargs)
        query.database = cls._get_read_database()
        return query

@classmethod
    def raw(cls, *args, **kwargs):
        query = super(ReadSlaveModel, cls).raw(*args, **kwargs)
        if query._sql.lower().startswith('select'):
            query.database = cls._get_read_database()
        return query

""" Support for using a dedicated read-slave. The read database is specified as a Model.Meta option, and will be used for SELECT statements: master = PostgresqlDatabase('master') read_slave = PostgresqlDatabase('read_slave') class BaseModel(ReadSlaveModel): class Meta: database = master read_slaves = [read_slave] # This database will be used for SELECTs. # Now define your models as you would normally. class User(BaseModel): username = CharField() # To force a SELECT on the master database, you can instantiate the SelectQuery # by hand: master_select = SelectQuery(User).where(...) """ from peewee import * class ReadSlaveModel(Model): @classmethod def _get_read_database(cls): if not getattr(cls._meta, 'read_slaves', None): return cls._meta.database current_idx = getattr(cls, '_read_slave_idx', -1) cls._read_slave_idx = (current_idx + 1) % len(cls._meta.read_slaves) return cls._meta.read_slaves[cls._read_slave_idx] @classmethod def select(cls, *args, **kwargs): query = super(ReadSlaveModel, cls).select(*args, **kwargs) query.database = cls._get_read_database() return query @classmethod def raw(cls, *args, **kwargs): query = super(ReadSlaveModel, cls).raw(*args, **kwargs) if query._sql.lower().startswith('select'): query.database = cls._get_read_database() return query