|
@@ -18,7 +18,7 @@ logger = logging.getLogger(__name__)
|
|
|
|
|
|
|
|
|
|
def insert(item, table_name):
|
|
def insert(item, table_name):
|
|
- con = pymysql.connect(host='192.168.0.184', user='hcst', passwd='hcst@2021', charset='utf8', port=3390)
|
|
|
|
|
|
+ con = pymysql.connect(host='192.168.0.101', user='hcst', passwd='hcst@2024', charset='utf8', port=3390)
|
|
async_item = tuple(item.values())
|
|
async_item = tuple(item.values())
|
|
# 对数据库进行插入操作,并不需要commit,twisted会自动commit
|
|
# 对数据库进行插入操作,并不需要commit,twisted会自动commit
|
|
placeholders = ', '.join(['%s'] * len(item))
|
|
placeholders = ', '.join(['%s'] * len(item))
|
|
@@ -37,7 +37,7 @@ def insert(item, table_name):
|
|
|
|
|
|
|
|
|
|
def batch_insert(item_list, table_name):
|
|
def batch_insert(item_list, table_name):
|
|
- con = pymysql.connect(host='192.168.0.184', user='hcst', passwd='hcst@2021', charset='utf8', port=3390)
|
|
|
|
|
|
+ con = pymysql.connect(host='192.168.0.101', user='hcst', passwd='hcst@2024', charset='utf8', port=3390)
|
|
# 对数据库进行插入操作,并不需要commit,twisted会自动commit
|
|
# 对数据库进行插入操作,并不需要commit,twisted会自动commit
|
|
placeholders = ', '.join(['%s'] * len(tuple(item_list[0])))
|
|
placeholders = ', '.join(['%s'] * len(tuple(item_list[0])))
|
|
columns = ', '.join(item_list[0].keys())
|
|
columns = ', '.join(item_list[0].keys())
|