python连接mariadb数据库写入数据
2021/7/3 19:52:35
本文主要是介绍python连接mariadb数据库写入数据,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
1、逻辑
根据每日生成的一个全网设备信息:设备名、厂商、设备型号、IP、版本、存活时间自动先生成一个.CSV文件,python通过pymysql库连接数据库将设备基础信息csv文件写入数据库(逐条写入)。
import pymysql def main(): try: csv_file_path='/home/zhangli/sw_list.csv' file = open(csv_file_path, 'r',encoding='utf-8') reader = file.readline() b = reader.split(',') colum = '' for a in b: colum = colum + a + ' varchar(255),' colum = colum[:-1] #定义table名字 table_name = 'ETCD' #定义要插入的数据 #ata = "LOAD DATA LOCAL INFILE '%s' INTO TABLE %s FIELDS TERMINATED BY ',' LINES TERMINATED BY '\\r\\n' IGNORE 1 LINES" % (csv_filename,table_name) #连接数据库 conn = pymysql.connect(host='localhost',port=3306,user='root',passwd='admin123',db='NET',charset='utf8') #创建游标对象 cursor = conn.cursor() #定义数据库 database='NET' #创建table create_table = 'create table if not exists ' + table_name + ' ' + '(' + colum + ')' + ' DEFAULT CHARSET=utf8' #执行 cursor.execute('drop table %s' % table_name) cursor.execute('use %s' % database) cursor.execute(create_table) #创建sql语句 for line in file: line=line.replace("\n","") f_read=line.split(',') if f_read[0] == 'sw_name': continue else: sw_name=f_read[0] ip=f_read[1] data_info=' values('+"\""+sw_name+"\""','+"\""+ip+"\""')' sql = 'insert into '+table_name+data_info cursor.execute(sql) #提交事务 conn.commit() cursor.close() conn.close() except Exception as err: print(err) main()
这篇关于python连接mariadb数据库写入数据的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-08有遇到过吗?同样的规则 Excel 中 比Python 结果大
- 2024-03-30开始python成长之路
- 2024-03-29python optparse
- 2024-03-29python map 函数
- 2024-03-20invalid format specifier python
- 2024-03-18pool.map python
- 2024-03-18threads in python
- 2024-03-14python Ai 应用开发基础训练,字符串,字典,文件
- 2024-03-13id3 algorithm python
- 2024-03-13sum array elements python