#!/usr/bin/env python

 # coding: utf-8

 # author: chenjie131@ke.com

 '''

 应用场景:

     将excel等存储的数据导入到 Mysql, 适用于追加表, 或者追加数据.

     1. 数据库表已存在, 可在需表后面添加数据.

     2. 数据库表不存在, 导入时直接创建表在数据库中.

     3. 特点:

         3.1 这里用pandas.to_sql()方法, 以块的方式导入效率高, 10000行100列的表,2.5s 导完.

         3.2 替代品,sql方式可参考load data local ....

         3.3 缺点是如果表存在, 且设置主键约束, 就不适用

 '''

 import pandas as pd

 from sqlalchemy import create_engine

 文件路径 = "C:\\Users\beike\\Desktop\\8月带看明细8.15.xls"

 # 1. 读取excel, sheet_name: 默认读取Sheet1,按需指定

 table = pd.read_excel(文件路径, sheet_name="明细")

 # 2. 连接MySql数据库, //后的参数为: 用户名, 密码, 主机, 数据库名

 engine = create_engine("mysql+pymysql://zmj:123456@192.168.6.81:3306/new_house")

 # 3. 连接测试

 try:

     pd.read_sql("show tables;", con=engine); print("connect successfully!")

 except Exception as error:

     print("connect fail! because of :", error)

 # 4. to_sql()方法插入数据, 更多细节自行查文档

     # 参数1: 表的名字,建议不要用中文

     # con: 之前创建的连接对象

     # if_exists:

                 # "replace": 如果传入的表名在库里存在, 则会删掉该表, 重新创建

                 # "append":  如果传入的表名在库里存在, 则会追加数据, 注意字段顺序一致, 注意当有主键约束则易报错

 try:

     table.to_sql("测试表", con=engine, index=False, if_exists="replace");

     print("insert successfully!")

 except Exception as error: print("insert fail! because of:", error)

 print("##"*20)

 print("done!")