当前位置: 首页 > 编程笔记 >

python 从csv读数据到mysql的实例

孟翰海
2023-03-14
本文向大家介绍python 从csv读数据到mysql的实例,包括了python 从csv读数据到mysql的实例的使用技巧和注意事项,需要的朋友参考一下

如下所示:

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 从csv读数据到mysql的实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持小牛知识库。

 类似资料:
  • 我有以下格式的文件

  • 本文向大家介绍python 读取.csv文件数据到数组(矩阵)的实例讲解,包括了python 读取.csv文件数据到数组(矩阵)的实例讲解的使用技巧和注意事项,需要的朋友参考一下 利用numpy库 (缺点:有缺失值就无法读取) 读: 写: 可能遇到的问题: 原因是文件路径名中含有转义字符,将路径中的\换成\即可。 利用pandas库 读:(可以处理缺失值) 写:(将dataFrame直接写入) 利

  • 问题内容: 我正在从包含以下数据的CSV文件(xyz.CSV)中读取数据: 当我使用循环对其进行迭代时,我可以按以下代码逐行打印数据,并且仅打印column1数据。 通过上面的代码,我只能得到第一列。 如果我尝试打印line [1]或line [2],则会出现以下错误。 请建议打印列2或列3的数据。 问题答案: 这是我获得第二列和第三列的方法: 结果如下:

  • 问题内容: 不知道我在这里缺少什么,但是这段代码运行时没有任何错误消息,但是表中没有任何内容。我正在将三列的CSV值加载到mysql表中 如果有人可以看看,将不胜感激。 谢谢。 问题答案: 我认为您必须将所有内容插入。 像这样

  • 问题内容: 我正在尝试使用Java + Hibernate + Spring将CSV文件加载到mySQL数据库中。我在DAO中使用以下查询来帮助我加载到数据库中: 我有一些想法可以从http://dev.mysql.com/doc/refman/5.1/en/load- data.html 使用它,以及如何从hibernate +spring应用程序将csv文件导入到mysql中? 但是我得到了错

  • 本文向大家介绍python之从文件读取数据到list的实例讲解,包括了python之从文件读取数据到list的实例讲解的使用技巧和注意事项,需要的朋友参考一下 背景: 文件内容每一行是由N个单一数字组成的,每个数字之间由制表符区分,比如: 0 4 3 1 2 2 1 0 3 1 2 0 …… 现在需要将每一行数据存为一个list,然后所有行组成一个大的list 工具: 1.strip():用于移除