110 cnx.commit() |
110 cnx.commit() |
111 with self.admin_access.repo_cnx() as cnx: |
111 with self.admin_access.repo_cnx() as cnx: |
112 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
112 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
113 indexes = [r[0] for r in crs.fetchall()] |
113 indexes = [r[0] for r in crs.fetchall()] |
114 self.assertNotIn('entities_pkey', indexes) |
114 self.assertNotIn('entities_pkey', indexes) |
115 self.assertNotIn('unique_entities_extid_idx', indexes) |
115 self.assertNotIn('entities_extid_idx', indexes) |
116 self.assertNotIn('owned_by_relation_pkey', indexes) |
116 self.assertNotIn('owned_by_relation_pkey', indexes) |
117 self.assertNotIn('owned_by_relation_to_idx', indexes) |
117 self.assertNotIn('owned_by_relation_to_idx', indexes) |
118 |
118 |
119 def test_drop_index_recreation(self): |
119 def test_drop_index_recreation(self): |
120 with self.admin_access.repo_cnx() as cnx: |
120 with self.admin_access.repo_cnx() as cnx: |
123 cnx.commit() |
123 cnx.commit() |
124 with self.admin_access.repo_cnx() as cnx: |
124 with self.admin_access.repo_cnx() as cnx: |
125 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
125 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
126 indexes = [r[0] for r in crs.fetchall()] |
126 indexes = [r[0] for r in crs.fetchall()] |
127 self.assertIn('entities_pkey', indexes) |
127 self.assertIn('entities_pkey', indexes) |
128 self.assertIn('unique_entities_extid_idx', indexes) |
128 self.assertIn('entities_extid_idx', indexes) |
129 self.assertIn('owned_by_relation_p_key', indexes) |
129 self.assertIn('owned_by_relation_p_key', indexes) |
130 self.assertIn('owned_by_relation_to_idx', indexes) |
130 self.assertIn('owned_by_relation_to_idx', indexes) |
131 |
131 |
132 def test_eids_seq_range(self): |
132 def test_eids_seq_range(self): |
133 with self.admin_access.repo_cnx() as cnx: |
133 with self.admin_access.repo_cnx() as cnx: |
206 slave_store = MassiveObjectStore(cnx, slave_mode=True) |
206 slave_store = MassiveObjectStore(cnx, slave_mode=True) |
207 with self.admin_access.repo_cnx() as cnx: |
207 with self.admin_access.repo_cnx() as cnx: |
208 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
208 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
209 indexes = [r[0] for r in crs.fetchall()] |
209 indexes = [r[0] for r in crs.fetchall()] |
210 self.assertIn('entities_pkey', indexes) |
210 self.assertIn('entities_pkey', indexes) |
211 self.assertIn('unique_entities_extid_idx', indexes) |
211 self.assertIn('entities_extid_idx', indexes) |
212 self.assertIn('owned_by_relation_p_key', indexes) |
212 self.assertIn('owned_by_relation_p_key', indexes) |
213 self.assertIn('owned_by_relation_to_idx', indexes) |
213 self.assertIn('owned_by_relation_to_idx', indexes) |
214 |
214 |
215 def test_slave_mode_exception(self): |
215 def test_slave_mode_exception(self): |
216 with self.admin_access.repo_cnx() as cnx: |
216 with self.admin_access.repo_cnx() as cnx: |
240 |
240 |
241 # Check index |
241 # Check index |
242 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
242 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
243 indexes = [r[0] for r in crs.fetchall()] |
243 indexes = [r[0] for r in crs.fetchall()] |
244 self.assertNotIn('entities_pkey', indexes) |
244 self.assertNotIn('entities_pkey', indexes) |
245 self.assertNotIn('unique_entities_extid_idx', indexes) |
245 self.assertNotIn('entities_extid_idx', indexes) |
246 self.assertNotIn('owned_by_relation_p_key', indexes) |
246 self.assertNotIn('owned_by_relation_p_key', indexes) |
247 self.assertNotIn('owned_by_relation_to_idx', indexes) |
247 self.assertNotIn('owned_by_relation_to_idx', indexes) |
248 |
248 |
249 # Cleanup -> index |
249 # Cleanup -> index |
250 store.finish() |
250 store.finish() |
251 |
251 |
252 # Check index again |
252 # Check index again |
253 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
253 crs = cnx.system_sql('SELECT indexname FROM pg_indexes') |
254 indexes = [r[0] for r in crs.fetchall()] |
254 indexes = [r[0] for r in crs.fetchall()] |
255 self.assertIn('entities_pkey', indexes) |
255 self.assertIn('entities_pkey', indexes) |
256 self.assertIn('unique_entities_extid_idx', indexes) |
256 self.assertIn('entities_extid_idx', indexes) |
257 self.assertIn('owned_by_relation_p_key', indexes) |
257 self.assertIn('owned_by_relation_p_key', indexes) |
258 self.assertIn('owned_by_relation_to_idx', indexes) |
258 self.assertIn('owned_by_relation_to_idx', indexes) |
259 |
259 |
260 def test_multiple_insert(self): |
260 def test_multiple_insert(self): |
261 with self.admin_access.repo_cnx() as cnx: |
261 with self.admin_access.repo_cnx() as cnx: |