Commita4a2ec3

committed

Create pg_query_state extension in the case of TPC-DS test

1 parent02049e1 commita4a2ec3Copy full SHA for a4a2ec3

File tree

-4

lines changed

-4

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ def teardown(con):`
`83`	`83`	`defmain(config):`
`84`	`84`	`''' Main test function '''`
`85`	`85`	`conn_params= {`
`86`		`-key:config.__dict__[key]forkeyin ('host','port','user','database','password')`
	`86`	`+key:config.__dict__[key]forkeyin ('host','port','user','database','password')`
`87`	`87`	`}`
`88`	`88`
`89`	`89`	`ifconfig.use_tpcds:`

Lines changed: 6 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -526,14 +526,17 @@ def test_timing_buffers_conflicts(config):`
`526`	`526`	`classDataLoadException(Exception):pass`
`527`	`527`	`classStressTestException(Exception):pass`
`528`	`528`
`529`		`-defload_tpcds_data(config):`
`530`		`-print('LoadingTPC-DSdata...')`
	`529`	`+defsetup_tpcds(config):`
	`530`	`+print('Setting upTPC-DStest...')`
`531`	`531`	`subprocess.call(['./tests/prepare_stress.sh'])`
`532`	`532`
`533`	`533`	`try:`
`534`	`534`	`conn=psycopg2.connect(**config)`
`535`	`535`	`cur=conn.cursor()`
`536`	`536`
	`537`	`+# Create pg_query_state extension`
	`538`	`+cur.execute('CREATE EXTENSION IF NOT EXISTS pg_query_state')`
	`539`	`+`
`537`	`540`	`# Create tables`
`538`	`541`	`withopen('tmp_stress/tpcds-kit/tools/tpcds.sql','r')asf:`
`539`	`542`	`cur.execute(f.read())`
`@@ -561,7 +564,7 @@ def test_tpc_ds(config):`
`561`	`564`	`globalstress_in_progress`
`562`	`565`
`563`	`566`	`stress_in_progress=True`
`564`		`-load_tpcds_data(config)`
	`567`	`+setup_tpcds(config)`
`565`	`568`
`566`	`569`	`print('Preparing TPC-DS queries...')`
`567`	`570`	`# # Execute query in separate thread`

Comments

(0)