配线app可用

This commit is contained in:
zjk
2025-05-05 19:35:53 +08:00
parent 3e33c95cb1
commit c46edb0015
3 changed files with 25 additions and 22 deletions
+4 -13
View File
@@ -226,27 +226,18 @@ class DB:
self.conn.commit()
def _insert_data(self, table_name, data_dict):
print('-----------------insert_data start')
'''内部方法:执行实际的数据库插入操作'''
with self.lock:
try:
# 检查并建立连接
if not self.conn:
print('-----------------connecting to database')
self.connect()
print(f'-----------------connection status: {"connected" if self.conn else "disconnected"}')
if not self.conn:
print('-----------------connection failed')
return False
print(f'-----------------connection object: {self.conn}')
# 创建cursor
try:
print('-----------------creating cursor')
cursor = self.conn.cursor()
print('-----------------cursor created successfully')
except sqlite3.Error as e:
print(f'-----------------cursor creation failed: {e}')
return False
@@ -255,14 +246,14 @@ class DB:
columns = ', '.join(data_dict.keys())
placeholders = ', '.join(['?'] * len(data_dict))
query = f'INSERT INTO {table_name} ({columns}) VALUES ({placeholders})'
print(f'-----------------prepared query: {query}')
# print(f'-----------------prepared query: {query}')
# 执行查询
try:
print('-----------------executing query')
# print('-----------------executing query')
cursor.execute(query, list(data_dict.values()))
self.conn.commit()
print(f"-----------------Data inserted successfully into {table_name}")
# print(f"-----------------Data inserted successfully into {table_name}")
return True
except sqlite3.Error as e:
print(f"-----------------Error executing query: {e}")
@@ -274,7 +265,7 @@ class DB:
def insertHighVolBusData(self, data:msg_disHighVolBusFbMsg):
'''插入高压母线配电反馈数据'''
print('-----------------insertHighVolBusData')
# print('-----------------insertHighVolBusData')
data_dict = {
'fuelCellCircuitBreaker': data.fuelCellCircuitBreaker,
'powerLithiumBatteryCircuitBreaker': data.powerLithiumBatteryCircuitBreaker,