(self)
| 773 | schema = "changeme" |
| 774 | |
| 775 | def _init_dbs(self): |
| 776 | e = testing_engine("sqlite://") |
| 777 | with e.connect() as conn: |
| 778 | for i in range(1, 5): |
| 779 | conn.exec_driver_sql( |
| 780 | 'ATTACH DATABASE "shard%s_%s.db" AS shard%s' |
| 781 | % (i, provision.FOLLOWER_IDENT, i) |
| 782 | ) |
| 783 | |
| 784 | db1 = e.execution_options(schema_translate_map={"changeme": "shard1"}) |
| 785 | db2 = e.execution_options(schema_translate_map={"changeme": "shard2"}) |
| 786 | db3 = e.execution_options(schema_translate_map={"changeme": "shard3"}) |
| 787 | db4 = e.execution_options(schema_translate_map={"changeme": "shard4"}) |
| 788 | |
| 789 | self.engine = e |
| 790 | return db1, db2, db3, db4 |
| 791 | |
| 792 | def teardown_test(self): |
| 793 | testing_reaper.checkin_all() |
no test coverage detected