Commit4f49dde

committed

TestTestgresCommon.test_pgbench is added

- [del] TestTestgresLocal.test_pgbench- [del] TestTestgresRemote.test_pgbench

1 parent110947d commit4f49ddeCopy full SHA for 4f49dde

File tree

+21

-37

lines changed

+21

-37

lines changed

Lines changed: 21 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -38,6 +38,7 @@`
`38`	`38`	`importuuid`
`39`	`39`	`importos`
`40`	`40`	`importre`
	`41`	`+importsubprocess`
`41`	`42`
`42`	`43`
`43`	`44`	`@contextmanager`
`@@ -1100,6 +1101,26 @@ def test_get_pg_config2(self, node_svc: PostgresNodeService):`
`1100`	`1101`	`b=get_pg_config2(node_svc.os_ops,None)`
`1101`	`1102`	`assert (id(a)!=id(b))`
`1102`	`1103`
	`1104`	`+deftest_pgbench(self,node_svc:PostgresNodeService):`
	`1105`	`+assertisinstance(node_svc,PostgresNodeService)`
	`1106`	`+`
	`1107`	`+__class__.helper__skip_test_if_util_not_exist(node_svc.os_ops,"pgbench")`
	`1108`	`+`
	`1109`	`+with__class__.helper__get_node(node_svc).init().start()asnode:`
	`1110`	`+# initialize pgbench DB and run benchmarks`
	`1111`	`+node.pgbench_init(`
	`1112`	`+scale=2,`
	`1113`	`+foreign_keys=True,`
	`1114`	`+options=['-q']`
	`1115`	`+ ).pgbench_run(time=2)`
	`1116`	`+`
	`1117`	`+# run TPC-B benchmark`
	`1118`	`+proc=node.pgbench(stdout=subprocess.PIPE,`
	`1119`	`+stderr=subprocess.STDOUT,`
	`1120`	`+options=['-T3'])`
	`1121`	`+out=proc.communicate()[0]`
	`1122`	`+assert (b'tps = 'inout)`
	`1123`	`+`
`1103`	`1124`	`@staticmethod`
`1104`	`1125`	`defhelper__get_node(node_svc:PostgresNodeService,name=None):`
`1105`	`1126`	`assertisinstance(node_svc,PostgresNodeService)`

Lines changed: 0 additions & 21 deletions

Original file line number	Diff line number	Diff line change
`@@ -100,27 +100,6 @@ def test_custom_init(self):`
`100`	`100`	`# there should be no trust entries at all`
`101`	`101`	`assertnot (any('trust'insforsinlines))`
`102`	`102`
`103`		`-deftest_pgbench(self):`
`104`		`-__class__.helper__skip_test_if_util_not_exist("pgbench")`
`105`		`-`
`106`		`-withget_new_node().init().start()asnode:`
`107`		`-`
`108`		`-# initialize pgbench DB and run benchmarks`
`109`		`-node.pgbench_init(scale=2,foreign_keys=True,`
`110`		`-options=['-q']).pgbench_run(time=2)`
`111`		`-`
`112`		`-# run TPC-B benchmark`
`113`		`-proc=node.pgbench(stdout=subprocess.PIPE,`
`114`		`-stderr=subprocess.STDOUT,`
`115`		`-options=['-T3'])`
`116`		`-`
`117`		`-out,_=proc.communicate()`
`118`		`-out=out.decode('utf-8')`
`119`		`-`
`120`		`-proc.stdout.close()`
`121`		`-`
`122`		`-assert ('tps'inout)`
`123`		`-`
`124`	`103`	`deftest_pg_config(self):`
`125`	`104`	`# check same instances`
`126`	`105`	`a=get_pg_config()`

Lines changed: 0 additions & 16 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,6 @@`
`1`	`1`	`# coding: utf-8`
`2`	`2`	`importos`
`3`	`3`	`importre`
`4`		`-importsubprocess`
`5`	`4`
`6`	`5`	`importpytest`
`7`	`6`	`importlogging`
`@@ -169,21 +168,6 @@ def test_init__unk_LANG_and_LC_CTYPE(self):`
`169`	`168`	`__class__.helper__restore_envvar("LC_CTYPE",prev_LC_CTYPE)`
`170`	`169`	`__class__.helper__restore_envvar("LC_COLLATE",prev_LC_COLLATE)`
`171`	`170`
`172`		`-deftest_pgbench(self):`
`173`		`-__class__.helper__skip_test_if_util_not_exist("pgbench")`
`174`		`-`
`175`		`-with__class__.helper__get_node().init().start()asnode:`
`176`		`-# initialize pgbench DB and run benchmarks`
`177`		`-node.pgbench_init(scale=2,foreign_keys=True,`
`178`		`-options=['-q']).pgbench_run(time=2)`
`179`		`-`
`180`		`-# run TPC-B benchmark`
`181`		`-proc=node.pgbench(stdout=subprocess.PIPE,`
`182`		`-stderr=subprocess.STDOUT,`
`183`		`-options=['-T3'])`
`184`		`-out=proc.communicate()[0]`
`185`		`-assert (b'tps = 'inout)`
`186`		`-`
`187`	`171`	`deftest_pg_config(self):`
`188`	`172`	`# check same instances`
`189`	`173`	`a=get_pg_config()`

Comments

(0)