我们要读取CSV文件的内容，并且要把数据存入数据库

首先与数据库建立连接

port是数据库端口一般3306，user是创建数据库的用户名，password是数据库连接密码，db数据库名称

#建立连接
conn = pymysql.connect(host='localhost', port=3306, user='***', password='****', db = db_name, charset='utf8')
#建立游标对象
cursor = conn.cursor()

读取csv文件的内容

url是你本地csv文件的路径，注意如果路径带中文名不要直接pd.read_csv(“url”),会报错

#调用pandas，获得.csv文件
    f = open('url')
    df = pd.read_csv(f)

之后就循环遍历每条数据，并且插入数据库

每条数据单独添加，故需要每次重写sql语句

    for each in df.values:
        #每条数据应该单独添加，故需要重写sql语句
        sql = 'insert into ' + table_name + ' values('
        for i,n in enumerate(each):
            if i < (len(each) -  1):
                sql = sql + str(n) + ','
            else:
                sql = sql + str(n) + ')'
        sql = sql + ';'
        #print(sql)
        #一条sql语句生成，提交执行
        cursor.execute(sql)
        conn.commit()

踩过的坑

1、建立连接，数据库一定要存在，名称一定要对，否则报错database不存在
2、pandas读取.csv文件，但是文件路径有中文，故需要用以下方式读取，若直接 df = pd.read_csv(‘url’）会报错，巴拉巴拉一大堆
f = open(‘url’)
df = pd.read_csv(f)
3、数据库中要先创建好表table，并且存放格式一定要和table表中的格式对应

完整代码

import pymysql
import pandas as pd


def get_con(db_name):
    #建立连接
    conn = pymysql.connect(host='localhost', port=3306, user='***', password='***', db = db_name, charset='utf8')
    #建立游标对象
    cursor = conn.cursor()
    return conn, cursor

def insert_Data(db_name, table_name):
    #调用get_con返回conn, cursor
    conn, cursor = get_con(db_name)
    #调用pandas，获得.csv文件
    f = open('url')
    df = pd.read_csv(f)
    #循环遍历df，获取每一条数据
    #count记录数据条数
    count = 0
    for each in df.values:
        #每条数据应该单独添加，故需要重写sql语句
        sql = 'insert into ' + table_name + ' values('
        for i,n in enumerate(each):
            if i < (len(each) -  1):
                sql = sql + str(n) + ','
            else:
                sql = sql + str(n) + ')'
        sql = sql + ';'
        #print(sql)
        #一条sql语句生成，提交执行
        cursor.execute(sql)
        conn.commit()
        #每提交一次，count加一
        count = count + 1

    print(str(count) + '条数据提交成功！')
    return conn, cursor

def main(db_name, table_name):
    conn, cursor = insert_Data(db_name, table_name)
    conn.close()
    cursor.close()

if __name__ == '__main__':
    main('map_data', 'pipedatas')

附数据库增删改查操作命令

数据库基本操作：增删改查
选择：select * from table1 where 范围
插入：insert into table1(field1,field2) values(value1,value2)
删除：delete from table1 where 范围
更新：update table1 set field1=value1 where 范围
查找：select * from table1 where field1 like ’%value1%’ —like的语法很精妙，查资料!
排序：select * from table1 order by field1,field2 [desc]
总数：select count as totalcount from table1
求和：select sum(field1) as sumvalue from table1
平均：select avg(field1) as avgvalue from table1
最大：select max(field1) as maxvalue from table1
最小：select min(field1) as minvalue from table1