python读取word文档,插入mysql数据库的示例代码


						表格内容如下：



1、实现批量导入word文档，取文档标题中的数字作为编号

2、除取上面打钩的内容需要匹配出来入库入库，其他内容全部直接入库mysql





# wuyanfeng

# -*- coding:utf-8 -*-

# 读取docx中的文本代码示例

import docx

import pymysql

import re

import os



# 创建数据库链接

conn = pymysql.connect(

 host='rm-bp1vu5d84dg12c6d59o.mysql.rds.aliyuncs.com',

 port=3306,

 user='root',

 passwd='wYf092415*',

 db='pays',

 charset='utf8',

)

# 创建游标

cursor = conn.cursor()



#切片函数

def section(info,key,len11):

 a = len(info)

 print(a, type(a))

 d = []

 e = 0

 g = -1

 i = 0

 task_class=[]

 while i < len(info):

  # for i in range(len(info)):

  # i+=1

  print("i::::", i)

  try:

   #c = info.index("a", e)

   #print("c:::::", c)

   c = info.index(key, e)

   #print("c:::::", c)



   print("c类型判断",type(c))

  except ValueError:

   print(ValueError)

  try:

   if (c != '') & (g < int(c)):

    d.append(c)

    g = c

    i = c + 1

    print("illlldddd:", i)

    e = c + 1

    continue



   elif (c == ''):

     break

  except UnboundLocalError:

   print(UnboundLocalError)



   return task_class

  break

 print("d", d, type(d))

 print(d[0], type(d[0]))

 print("d的长度：",len(d))

 #开始切片

 if len(d) != 0:

  for j in range(len(d)):

   print("info11:::", info, type(info))

   info = ''.join(info)

   print("info222:::",info,type(info))

   print("d[%d]"%j,d[j])

   #print("d[j]:5"%j,info[d[j]:5])



   llll = info[d[j]+1:d[j]+5]

   print("d[%d]:5" % j, llll)

   task_class.append(llll)

   print("task_class::11", task_class)



 task_class=",".join(task_class)

 print("str1112222",task_class)

 return task_class





def insettable(file):

 print("file：：：:::::::::::::::::", file)

 print("type：：：:::::::::::::::::", type(file))

 # file1 = file

 # file1 = str(file1)

 ddd = re.findall("知识库\\\(\d+)", file)

 print("ddd：::::::::：：", ddd)

 print("ddd[0]:::", ddd[0])

 ddd = int(ddd[0])

 print("ddd::::", type(ddd))



 file = docx.Document(file)

 # 读取表格：

 t = file.tables[0]

 print(t)

 print("1:", t.cell(0, 0).text) # 1

 cell1 = t.cell(0, 0).text

 print("tyep::::", type(t.cell(0, 0).text))



 print("2:", t.cell(0, 1).text) # 2

 cell2 = t.cell(0, 1).text



 print("2:", t.cell(0, 2).text) # 2

 cell3 = t.cell(0, 2).text



 print("2:", t.cell(0, 3).text) # 2

 cell4 = t.cell(0, 3).text

 print("cell4:::::::::", cell4)



 print("3:", t.cell(1, 0).text) # 3

 cell5 = t.cell(1, 0).text



 print("4:", t.cell(1, 2).text) # 4

 cell6 = t.cell(1, 2).text



 print("5:", t.cell(1, 3).text) # 5

 task_type = t.cell(1, 3).text

 # task_type = re.findall('.*[&#9745;√](.*)$', cell7)

 # task_type = ''.join(cell7)

 print("task_type111111:", task_type)

 # task_class = task_class[0:4]

 '''低级处理方式

 a = int(task_type.count("&#9745;"))

 print("a|||||||", a, type(a))

 b = int(task_type.count("√"))

 print("b|||||||", b, type(a))

 if (a == 1) | (b == 1):

  print("111111111111111111")

  # task_type = re.findall('.*[&#9745;√](.*)$', task_type)

  task_type = re.findall('.*[&#9745;√](.*)$', task_type)

  print("task_type1", task_type)

  task_type = ''.join(task_type)

  print("task_type2", task_type)

  task_type = task_type[0:4]

  print("task_type3:d:%s，b=%d" % (a, b), task_type)

 elif (a == 0) & (b == 0):

  print("2222222222222222222")

  task_type = '法定职责'

  print("a:%s，b=%s" % (a, b), task_type)

 elif (a == 2) | (b == 2):

  print("333333333333333333333")

  task_type = '法定职责,工作职责 '

  print("a:%s，b=%s" % (a, b), task_type)

 '''

 #调用切片函数

 task_type1 = section(task_type, "√", 4)

 task_type2 = section(task_type, "&#9745;", 4)

 task_type1 = "".join(task_type1)

 task_type2 = "".join(task_type2)

 print("task_type1:::", task_type1,type(task_type1))

 print("task_type2:::", task_type2,type(task_type2))

 if task_type1.strip()!="":

  task_type = task_type1

  print("task_type111:::", task_type1)

 elif task_type2.strip()!="":

  task_type = task_type2

  print("task_type222:::", task_type2)



 print("6:", t.cell(1, 4).text) # 6

 cell8 = t.cell(1, 4).text



 print("7:", t.cell(2, 1).text) # 7

 cell9 = t.cell(2, 1).text



 # 获取文档对象

 # file = docx.Document("D:\\配置库\\公案APP\\1.2 系统规格\\知识库\\14人员死亡先期处置.docx")

 print("段落数:" + str(len(file.paragraphs))) # 段落数为13，每个回车隔离一段

 lenn = len(file.paragraphs)

 print("len:", lenn)

 # 输出每一段的内容

 for para in file.paragraphs:

  print(para.text)



 # 输出段落编号及段落内容

 for i in range(len(file.paragraphs)):

  print("第" + str(i) + "段的内容是：" + file.paragraphs[i].text)



 list6 = []

 for i in range(len(file.paragraphs)):

  if 0 == i:

   print("i:", i)

   lis0 = file.paragraphs[i].text

   print("list0:", lis0)

   print(type(lis0))



  elif 1 == i:

   print("i:", i)

   task_class = file.paragraphs[i].text

   print("lis1", task_class,type(task_class))

   '''低级处理方式

   print("task_class111111:", task_class)



   c = int(task_class.count("&#9745;"))

   task_class = ''.join(task_class)

   #print(task_class.index('&#9745;'))

   print("c|||||||", c, type(c))

   d = int(task_class.count("√"))

   print(task_class.index('√'))



   print("d|||||||", d, type(d))

   task_class = re.findall(r'[&#9745;√](?:.*)', task_class)

   task_class = ''.join(task_class)

   task_class = task_class[1:5]

   print("task_class", task_class)

  '''

   #调用切片函数

   task_class1 = section(task_class, "√", 4)

   task_class2 = section(task_class, "&#9745;", 4)

   task_class1 = "".join(task_class1)

   task_class2 = "".join(task_class2)

   print("task_class1:::", task_class1,type(task_class1))

   print("task_class2:::", task_class2,type(task_class2))

   if task_class1.strip()!="":

    task_class = task_class1

    print("task_class11:::", task_class1)

   elif task_class2.strip()!="":

    task_class = task_class2

    print("task_class22:::", task_class2)





  if 2 == i:

   print("i:", i)

   lis2 = file.paragraphs[i].text



   print("lis2", lis2)

   print(type(lis2))

   preparer = re.findall('填表单位：(.*?)$', lis2)

   preparer = ''.join(preparer)

   print("preparer:%s" % preparer)



  # elif 3 == i:

  #  print("i:", i)

  #  lis3 = file.paragraphs[i].text

  elif 3 == i:

   print("i:", i)

   lis4 = file.paragraphs[i].text

   print("lis4", lis4)

   print(type(lis4))

  elif 3 < i < lenn - 1:

   print("i:", i)

   print(file.paragraphs[i].text)

   print(type(file.paragraphs[i].text))

   # list6[i-5] = list6.append(file.paragraphs[i].text)

   list6.append(str(file.paragraphs[i].text).strip('\xa0'))

   # list6.append("%s\n" % str(file.paragraphs[i].text).strip('\xa0'))

   print(list6)

 key_steps = "\n".join(list6)

 # print("key_steps:\n",key_steps.strip('\n'))



 cursor.execute(

  "insert into `t_knowledge_base` (`no`, `preparer`, `task_class`, `task_name`, `task_specification`, `task_type`, `task_desc`, `task_basis`, `key_steps`) values ('%d','%s','%s','%s','%s','%s','%s',NULL,'%s')" % (

   ddd, preparer, task_class, cell2, cell4, task_type, cell9, key_steps))

 conn.commit()





def traverse(f):

 fs = os.listdir(f)

 for f1 in fs:

  tmp_path = os.path.join(f, f1)

  if not os.path.isdir(tmp_path):

   print('文件: %s' % tmp_path)

   insettable(tmp_path)

  else:

   print('文件夹：%s' % tmp_path)

   traverse(tmp_path)





path = 'D:\\配置库\公案APP\\1.2 系统规格\\知识库'

traverse(path)



#单文件调测

# path = 'D:\\配置库\\公案APP\\1.2 系统规格\\知识库\\14人员死亡先期处置.docx'

# insettable(path)



# 关闭游标

cursor.close()

# 关闭连接

conn.close()





以上这篇python读取word文档,插入mysql数据库的示例代码就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持中文源码网。