Skip to content

I
InterfaceAutoTest
Commit f095cf4a by taoke
Options

数据库操作_调整成另一个数据库

parent 66ef76ed
Showing with 32 additions and 33 deletions
test_case/bmc/test_ ElectronicLicense.py
...@@ -36,10 +36,9 @@ def get_vehickleId_Tounbind(): ...@@ -36,10 +36,9 @@ def get_vehickleId_Tounbind():
@pytest.fixture(scope='function') @pytest.fixture(scope='function')
def avatarUpdate_del() : #修改头像清除 def avatarUpdate_del() : #修改头像清除
mysql=BaseConfig.test_mysql_215 # mysql=BaseConfig.test_mysql_215
mysql = MYSQL(*mysql) # mysql = MYSQL(*mysql)
mysql = MYSQL(host="10.197.236.190", port=3306, user="root", pwd="123456", db="edl_private")
# mysql = MYSQL(host="10.197.236.190", port=3306, user="root", pwd="123456", db="edl_private")
# mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", "edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", "edl_public")
mysql.ExecuNonQuery( mysql.ExecuNonQuery(
"DELETE FROM edl_private.driving_license_image_audit WHERE name='自动化';") # 删除驾驶员 "DELETE FROM edl_private.driving_license_image_audit WHERE name='自动化';") # 删除驾驶员
......
test_case/bmc/test_accountinfo.py
...@@ -54,8 +54,8 @@ class TestRegister(): ...@@ -54,8 +54,8 @@ class TestRegister():
def setup_class(self): def setup_class(self):
# def test_mysql_result(self): # def test_mysql_result(self):
"""数据库操作""" """数据库操作"""
# self.ms = MYSQL('10.197.236.190', 3306, 'root', '123456', 'edl_public') self.ms = MYSQL('10.197.236.190', 3306, 'root', '123456', 'edl_public')
self.ms = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", "edl_public") # self.ms = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", "edl_public")
# mysql = BaseConfig.test_mysql_215 # mysql = BaseConfig.test_mysql_215
# self.ms = MYSQL(*mysql) # self.ms = MYSQL(*mysql)
......
test_case/bmc/test_my.py
...@@ -23,8 +23,8 @@ class TestMy: ...@@ -23,8 +23,8 @@ class TestMy:
config.BMCConfig.headers["Pvt-Token"]=getattr(config.BMCConfig,"bmc_pvt_token") config.BMCConfig.headers["Pvt-Token"]=getattr(config.BMCConfig,"bmc_pvt_token")
config.BMCConfig.headers["Token"]=getattr(config.BMCConfig,"bmc_token") config.BMCConfig.headers["Token"]=getattr(config.BMCConfig,"bmc_token")
self.headers=config.BMCConfig.headers self.headers=config.BMCConfig.headers
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
mysql.ExecuNonQuery( "insert into edl_public.feedback_type values ('10008611','自动化类型','0','1','0','2021-05-01 16:51:12','2021-05-01 16:51:12','520100,330100,500100');") mysql.ExecuNonQuery( "insert into edl_public.feedback_type values ('10008611','自动化类型','0','1','0','2021-05-01 16:51:12','2021-05-01 16:51:12','520100,330100,500100');")
mysql.ExecuNonQuery( "INSERT INTO edl_public.trade (user_id,phone,brand_id,shop_id,trade_type,trade_amount,privilege_amount,pay_amount,uuid,trade_no,trade_source,memo,gmt_finished,status,gmt_create,gmt_modified,shop_name,brand_name,trade_status,remark_status,verification_status,settlement_status,refund_status,close_status,gmt_closed,close_memo,expired_status,gmt_expired,bill_status) VALUES (598137,'17822000000',48,112,2,2.55,0.00,2.55,'7ac6253d-8586-475d-8474-be848fe5c4b6','hik202105081390911897531973632',1,NULL ,NULL ,1,'2021-05-08 14:10:13.000','2021-05-24 17:25:30.000','回归测试门店1','回归（个人）1',3,'N/A','N/A','N/A','N/A','N/A',NULL,NULL,'N/A','2021-06-07 14:10:13.000','N/A');") mysql.ExecuNonQuery( "INSERT INTO edl_public.trade (user_id,phone,brand_id,shop_id,trade_type,trade_amount,privilege_amount,pay_amount,uuid,trade_no,trade_source,memo,gmt_finished,status,gmt_create,gmt_modified,shop_name,brand_name,trade_status,remark_status,verification_status,settlement_status,refund_status,close_status,gmt_closed,close_memo,expired_status,gmt_expired,bill_status) VALUES (598137,'17822000000',48,112,2,2.55,0.00,2.55,'7ac6253d-8586-475d-8474-be848fe5c4b6','hik202105081390911897531973632',1,NULL ,NULL ,1,'2021-05-08 14:10:13.000','2021-05-24 17:25:30.000','回归测试门店1','回归（个人）1',3,'N/A','N/A','N/A','N/A','N/A',NULL,NULL,'N/A','2021-06-07 14:10:13.000','N/A');")
...@@ -149,8 +149,8 @@ class TestMy: ...@@ -149,8 +149,8 @@ class TestMy:
def test_myinfoaddressupdate(self,indata): def test_myinfoaddressupdate(self,indata):
url=f'{config.BMCConfig.host}/{indata["url"]}' url=f'{config.BMCConfig.host}/{indata["url"]}'
method=indata["method"] method=indata["method"]
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
addressId=mysql.ExecuQuery("SELECT id FROM user_address WHERE address='接口自动化详细地址';")[-1]["id"] addressId=mysql.ExecuQuery("SELECT id FROM user_address WHERE address='接口自动化详细地址';")[-1]["id"]
if indata["reqData"]["address"]=="存在": if indata["reqData"]["address"]=="存在":
indata["reqData"]["addressId"]=addressId indata["reqData"]["addressId"]=addressId
...@@ -177,8 +177,8 @@ class TestMy: ...@@ -177,8 +177,8 @@ class TestMy:
def test_myinfoaddressdefault(self,indata): def test_myinfoaddressdefault(self,indata):
url=f'{config.BMCConfig.host}/{indata["url"]}' url=f'{config.BMCConfig.host}/{indata["url"]}'
method=indata["method"] method=indata["method"]
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
addressId = mysql.ExecuQuery("SELECT id FROM user_address WHERE address='接口自动化详细地址';")[-1]["id"] addressId = mysql.ExecuQuery("SELECT id FROM user_address WHERE address='接口自动化详细地址';")[-1]["id"]
if len(indata["reqData"]["addressId"])==0: if len(indata["reqData"]["addressId"])==0:
data = indata["reqData"] data = indata["reqData"]
...@@ -207,8 +207,8 @@ class TestMy: ...@@ -207,8 +207,8 @@ class TestMy:
url = f'{config.BMCConfig.host}/{indata["url"]}' url = f'{config.BMCConfig.host}/{indata["url"]}'
method = indata["method"] method = indata["method"]
expectdata = indata["expectData"] expectdata = indata["expectData"]
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
addressId = mysql.ExecuQuery("SELECT id FROM user_address WHERE address='接口自动化详细地址';")[-1]["id"] addressId = mysql.ExecuQuery("SELECT id FROM user_address WHERE address='接口自动化详细地址';")[-1]["id"]
if len(indata["reqData"]["addressId"])==0: if len(indata["reqData"]["addressId"])==0:
data = indata["reqData"] data = indata["reqData"]
...@@ -442,8 +442,8 @@ class TestMy: ...@@ -442,8 +442,8 @@ class TestMy:
indata["reqData"]["tradeId"]=1234567890 indata["reqData"]["tradeId"]=1234567890
data = indata["reqData"] data = indata["reqData"]
else: else:
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
tradeId = mysql.ExecuQuery("select id from edl_public.trade where status=1 and trade_status=2 limit 1;")[0]["id"] tradeId = mysql.ExecuQuery("select id from edl_public.trade where status=1 and trade_status=2 limit 1;")[0]["id"]
indata["reqData"]["tradeId"]=tradeId indata["reqData"]["tradeId"]=tradeId
data=indata["reqData"] data=indata["reqData"]
...@@ -467,15 +467,15 @@ class TestMy: ...@@ -467,15 +467,15 @@ class TestMy:
indata["reqData"]["tradeId"] = 1234567890 indata["reqData"]["tradeId"] = 1234567890
data = indata["reqData"] data = indata["reqData"]
else: else:
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
mysql.ExecuNonQuery("update edl_public.trade set trade_status='2'where user_id='598137';") mysql.ExecuNonQuery("update edl_public.trade set trade_status='2'where user_id='598137';")
tradeId=mysql.ExecuQuery("select id from edl_public.trade where trade_status=2 and user_id='598137';")[-1]["id"] tradeId=mysql.ExecuQuery("select id from edl_public.trade where trade_status=2 and user_id='598137';")[-1]["id"]
indata["reqData"]["tradeId"] = tradeId indata["reqData"]["tradeId"] = tradeId
data = indata["reqData"] data = indata["reqData"]
else: else:
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
mysql.ExecuNonQuery("update edl_public.trade set trade_status='1'where user_id='598137';") mysql.ExecuNonQuery("update edl_public.trade set trade_status='1'where user_id='598137';")
tradeId = mysql.ExecuQuery("select id from edl_public.trade where status=1 and user_id='598137';")[-1]["id"] tradeId = mysql.ExecuQuery("select id from edl_public.trade where status=1 and user_id='598137';")[-1]["id"]
indata["reqData"]["tradeId"] = tradeId indata["reqData"]["tradeId"] = tradeId
...@@ -532,8 +532,8 @@ class TestMy: ...@@ -532,8 +532,8 @@ class TestMy:
data = {"content":"自动化新用户意见数据","feedbackTypeId":feedbackTypeId} data = {"content":"自动化新用户意见数据","feedbackTypeId":feedbackTypeId}
method = "post" method = "post"
res=request_main(url,self.headers,method,data) res=request_main(url,self.headers,method,data)
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
feedbackId=mysql.ExecuQuery("select feedback_id from edl_public.feedback_chat_record where user_id='598137' and content='自动化新用户意见数据';")[-1]["feedback_id"] feedbackId=mysql.ExecuQuery("select feedback_id from edl_public.feedback_chat_record where user_id='598137' and content='自动化新用户意见数据';")[-1]["feedback_id"]
return feedbackId return feedbackId
...@@ -584,13 +584,13 @@ class TestMy: ...@@ -584,13 +584,13 @@ class TestMy:
expectdata = indata["expectData"] expectdata = indata["expectData"]
otherexpectData=indata["otherExpectData"] otherexpectData=indata["otherExpectData"]
if indata['testPoint']=="有未读信息": if indata['testPoint']=="有未读信息":
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
mysql.ExecuNonQuery("update edl_public.feedback_main set read_flag='0'where user_id='598137'and feedback_type_id='10008611';") mysql.ExecuNonQuery("update edl_public.feedback_main set read_flag='0'where user_id='598137'and feedback_type_id='10008611';")
mysql.ExecuNonQuery("update edl_public.feedback_main set status='1'where user_id='598137'and feedback_type_id='10008611';") mysql.ExecuNonQuery("update edl_public.feedback_main set status='1'where user_id='598137'and feedback_type_id='10008611';")
else: else:
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
mysql.ExecuNonQuery( "update edl_public.feedback_main set read_flag='1'where user_id='598137'and feedback_type_id='10008611';") mysql.ExecuNonQuery( "update edl_public.feedback_main set read_flag='1'where user_id='598137'and feedback_type_id='10008611';")
self.res = request_main(url, self.headers, method, data) self.res = request_main(url, self.headers, method, data)
try: try:
...@@ -617,16 +617,16 @@ class TestMy: ...@@ -617,16 +617,16 @@ class TestMy:
raise e raise e
def teardown(self): def teardown(self):
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
mysql.ExecuNonQuery("delete from edl_public.feedback_type where id='10008611';") mysql.ExecuNonQuery("delete from edl_public.feedback_type where id='10008611';")
mysql.ExecuNonQuery("delete from edl_public.feedback_chat_record where user_id='598137'") mysql.ExecuNonQuery("delete from edl_public.feedback_chat_record where user_id='598137'")
mysql.ExecuNonQuery("delete from edl_public.feedback_main where user_id='598137'") mysql.ExecuNonQuery("delete from edl_public.feedback_main where user_id='598137'")
allure.attach(f"{self.res}",'响应结果',allure.attachment_type.TEXT) allure.attach(f"{self.res}",'响应结果',allure.attachment_type.TEXT)
def teardown_class(self): def teardown_class(self):
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="edl_public")
mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public") # mysql = MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", db="edl_public")
mysql.ExecuNonQuery("update edl_public.user set nickname='自动化' where id='598137';") mysql.ExecuNonQuery("update edl_public.user set nickname='自动化' where id='598137';")
mysql.ExecuNonQuery( "delete from edl_public.user_address where user_id='598137'and address in ('接口自动化详细地址','存在');") mysql.ExecuNonQuery( "delete from edl_public.user_address where user_id='598137'and address in ('接口自动化详细地址','存在');")
mysql.ExecuNonQuery("delete from edl_public.trade where user_id='598137'and trade_no='hik202105081390911897531973632';") mysql.ExecuNonQuery("delete from edl_public.trade where user_id='598137'and trade_no='hik202105081390911897531973632';")
......
test_case/bmc/test_roadreview.py
...@@ -239,8 +239,8 @@ class TestRoadreview: ...@@ -239,8 +239,8 @@ class TestRoadreview:
def teardown_class(self): def teardown_class(self):
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="db_gy_dmsmp")
mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="db_gy_dmsmp") mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="db_gy_dmsmp")
# mysql = MYSQL("10.197.236.190", 3306, "root", "123456", db="db_gy_dmsmp")
mysql.ExecuNonQuery("delete from db_gy_dmsmp.occupy_road_apply where user_id='393038' and people_phone='18800000044' ;") mysql.ExecuNonQuery("delete from db_gy_dmsmp.occupy_road_apply where user_id='393038' and people_phone='18800000044' ;")
def teardown(self): def teardown(self):
......
test_case/bmc/test_vehicle_steward.py
...@@ -17,8 +17,8 @@ class TestVehicleSteward(): ...@@ -17,8 +17,8 @@ class TestVehicleSteward():
# def test_setup_class(self): # def test_setup_class(self):
"""链接数据库""" """链接数据库"""
# 出行服务 # 出行服务
# self.ms = MYSQL('10.197.236.190', 3306, 'root', '123456', 'edl_public') self.ms = MYSQL('10.197.236.190', 3306, 'root', '123456', 'edl_public')
self.ms=MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", "edl_public") # self.ms=MYSQL("10.197.236.215", 3306, "root", "DataCenter@!hik", "edl_public")
# 获取账号的userId -- 目前已经在excel中写死为 17822000000 账号的userId # 获取账号的userId -- 目前已经在excel中写死为 17822000000 账号的userId
resList = self.ms.ExecuQuery('SELECT * FROM edl_public.user where phone=17822000000;') resList = self.ms.ExecuQuery('SELECT * FROM edl_public.user where phone=17822000000;')
......
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