alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1812 #fix /home/tpc as global

Browse Source
This commit is contained in:
Peter Urbanetz 2020-05-19 13:19:32 +02:00 committed by Jiri Pechanec
parent 59162675c5
commit 6b0651f2bc
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
debezium-e2e-benchmark/py/tpc-run-test.py
View File

@ -16,6 +16,9 @@ import threading
import jpype
tpchomedir = "/home/tpc"
def initsql(conn, config, tpcconfig):
curs = conn.cursor()
for sql in tpcconfig['jdbc'][config['config']['connector.class'].split('.')[3]]['initsql']:
@ -64,13 +67,14 @@ def enablecdctablesql(conn, config, tpcconfig):
def topicexport(bootstrapserver, count, commitinterval):
global tpchomedir
consumer = KafkaConsumer('db2server.TPC.TEST',
bootstrap_servers=bootstrapserver,
auto_offset_reset='smallest',
enable_auto_commit=True,
)
i = 0
file = open("/home/tpc/tpcdata/" + "tpc_" + str(count) +
file = open(tpchomedir + "/tpcdata/" + "tpc_" + str(count) +
"_" + str(commitinterval) + ".csv", "w")
print('read from TOPIC')
for message in consumer:
@ -92,6 +96,7 @@ def topicexport(bootstrapserver, count, commitinterval):
def getjdbcconnection(config, tpcconfig):
global tpchomedir
connectiontype = config['config']['connector.class'].split('.')[3]
jdbctype = 'jdbc:' + connectiontype + '://'
if connectiontype == 'oracle':
@ -102,7 +107,7 @@ def getjdbcconnection(config, tpcconfig):
config['config']['database.dbname'],
[config['config']['database.user'],
config['config']['database.password']],
'/home/tpc/jdbcdriver/' + tpcconfig['jdbc'][connectiontype]['jar'])
tpchomedir + '/jdbcdriver/' + tpcconfig['jdbc'][connectiontype]['jar'])
return conn