class Mssql_csv(object):
#定义一个init方法,用于读取数据库
def __init__(self):
#读取数据库和建立游标对象
self.connect = pymssql.connect('(local)', 'sa', '123456', 'phm_data')
self.cursor = self.connect.cursor()
def read_csv_values(self):
# 读取csv文件数据
data = pd.read_csv('./PHM/Learning_set/Bearing1_1/acc_00001.csv', encoding="utf-8")
data_3 = list(data.values)
return data_3
def read_csv_colnmus(self):
data = pd.read_csv("I:/crack/DATA/myfir.csv", encoding="utf-8")
data_1 = list(data.columns)
return data_1
def write_mssql(self):
# 在数据表中写入数据,因为数据是列表类型,把他转化为元组更符合sql语句
for i in self.read_csv_values(): # 因为数据是迭代列表,所以用循环把数据提取出来
data_6 = tuple(i)
sql = """insert into Bearing1_1 values{}""".format(data_6)
self.cursor.execute(sql)
self.connect.commit()
print("植入完成")
def __del__(self):
self.connect.close()
self.cursor.close()
def run(self):
self.write_mssql()
def main():
sql = Mssql_csv()
sql.run()
if __name__ == '__main__':
main()
代码将csv文件存入sql数据库,然后查看数据库后发现csv表格的第一行没有存入数据库(就少了这一行),请问大佬们是哪里处理出错了?