python 从csv读数据到mysql

py3study

发布于 2020-01-11 22:17:59

1.3K0

发布于 2020-01-11 22:17:59

文章被收录于专栏：python3python3

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()

本文参与?腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2019-08-15 ，如有侵权请联系 cloudcommunity@tencent.com 删除

python