Commit d3b4fbf5 authored by Kazuhiko Shiozaki's avatar Kazuhiko Shiozaki

testInvalidationBug: generate transactionless connection string properly.

parent 828e4d5b
...@@ -28,6 +28,7 @@ ...@@ -28,6 +28,7 @@
# #
############################################################################## ##############################################################################
import re
import threading import threading
import unittest import unittest
import urllib import urllib
...@@ -61,10 +62,12 @@ class TestInvalidationBug(ERP5TypeTestCase): ...@@ -61,10 +62,12 @@ class TestInvalidationBug(ERP5TypeTestCase):
organisation.immediateReindexObject() # modify catalog organisation.immediateReindexObject() # modify catalog
path = organisation.getPath() path = organisation.getPath()
test_list = [] test_list = []
for connection_id, table in (('erp5_sql_connection', 'catalog'), for connection_id, table in (('erp5_sql_read_committed_connection', 'catalog'),
('cmf_activity_sql_connection', 'message')): ('cmf_activity_sql_connection', 'message')):
connection = self.portal[connection_id] connection = self.portal[connection_id]
query = connection.factory()('-' + connection.connection_string).query query = connection.factory()(
re.sub(r'((?:[%*][^ ]+ )*)(![^ ]+ )?(.+)', r'\1-\3', connection.connection_string)
).query
sql = "rollback\0select * from %s where path='%s'" % (table, path) sql = "rollback\0select * from %s where path='%s'" % (table, path)
test_list.append(lambda query=query, sql=sql: len(query(sql)[1])) test_list.append(lambda query=query, sql=sql: len(query(sql)[1]))
result_list = [map(apply, test_list)] result_list = [map(apply, test_list)]
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment