python 从csv读数据到mysql

发布时间：2019-08-15 09:59:24编辑：auto阅读（2295）

    import csv
import sys,os
import MySQLdb

def read_csv(filename):
    with open(filename) as f:
        f_csv = csv.reader(f)
        headers = next(f_csv)
        #数据格式[1111,22222,1111,1111,.....]
        #for row in f_csv:
            # Process row
        #    field1=row[1]
        #    ...
        return headers

def conn_to_psto():
    #mysql连接方法
    #MySQLdb.connect()
    #postgl连接
    onn = MySQLdb.connect(database="testdb", \
                           user="postgres", \
                           password="pass123",\
                            host="127.0.0.1",\
                             port="5432")
    cur = conn.cursor()
    return cur

if __name__ == "__main__":
    #传入文件路径或文件名
    filename=sys.argv[1]
    f_csv=read_csv(filename)
    cur=conn_to_psto()
    for row in f_csv:
            # Process row
            field1=row[1]
            ...
        sql='''insert into .......(field1,field2,...) values(%,%,...) '''.format(field1=field1,field2=field2.........))
        cur.execute(sql)
    conn.commit()
    conn.close()

关键字：

上一篇： python学习之数组查找。

下一篇： 【Python3.7学习笔记】三、变量和