代码如下:
import pymysql
import xlrd
import xlwt
from datetime import date,datetime
def read_excel():
# 打开文件
workbook = xlrd.open_workbook(r'F:\表名.xlsx')
# 获取所有sheet
print(workbook.sheet_names()) # [u'sheet1', u'sheet2']
sheet2_name = workbook.sheet_names()[0]
# 根据sheet索引或者名称获取sheet内容
sheet2 = workbook.sheet_by_index(0) # sheet索引从0开始
sheet2 = workbook.sheet_by_name(sheet2_name)
# sheet的名称,行数,列数
print (sheet2.name,sheet2.nrows,sheet2.ncols)
# 获取整行和整列的值(数组)
#rows = sheet2.row_values(3) # 获取第四行内容
#cols = sheet2.col_values(2) # 获取第三列内容
for row in range(sheet2.nrows):
#print (sheet2.cell(row,3))
#print (sheet2.cell(row,4))
try:
print(fun_get_vehichleInfo(sheet2.cell(row,3).value,sheet2.cell(row,4).value))
if(fun_get_vehichleInfo(sheet2.cell(row,3).value,sheet2.cell(row,4).value))==0:
fun_Insert_to_db(sheet2.cell(row,3).value,sheet2.cell(row,4).value)
except:
print ("Error: unable to fetch data")
print ('同步成功!')
def fun_Insert_to_db(sold,snew):
sql = "INSERT INTO Sheet1 (old,new) VALUES (%s,%s)"
val = (sold,snew)
cursor.execute(sql, val)
db.commit()
def fun_get_vehichleInfo(sold,snew):
sql = "SELECT * FROM Sheet1 WHERE old = %s and new = %s "
val = (sold,snew)
return cursor.execute(sql,val)
# 打开数据库连接
db = pymysql.connect("ip地址", "用户名", "密码", "数据库名",3306)
# 使用cursor()方法获取操作游标
cursor = db.cursor()
read_excel()
# 关闭数据库连接
db.close()
网友评论