hyadijxp 发表于 2018-8-10 11:36:29

python2.7 MySQLdb insert

python 1.py  

  
#!/usr/bin/env python
  
# -*- coding: utf-8 -*-
  

  
import sys
  
#import pymysql
  
#pymysql.install_as_MySQLdb()
  
import MySQLdb as mdb
  
con = mdb.connect('127.0.0.1', 'root', '123456', 'db03')
  

  
def test(param):
  
    with con:
  
      cur = con.cursor()
  
      # cur.execute("CREATE TABLE IF NOT EXISTS \
  
      #             Writers(Id INT PRIMARY KEY AUTO_INCREMENT, Name VARCHAR(25))";"INSERT INTO Writers(Name) VALUES('Jack London')")
  
      # cur.execute("INSERT INTO Writers(Name) VALUES('Jack London'),INSERT INTO Writers(Name) VALUES('Honore de Balzac')")
  
      # sql = 'INSERT INTO Writers(Name) VALUES(%s)'
  
      # param = ('Jack London', 'Honore de Balzac')
  
      # cur.executemany(sql, param)
  
      # sql="insert a(ip,yy) values(['tomcat', '192.1.1.121']); insert a(ip,yy) values(['redis', '192.1.1.122']);"
  
      # cur.execute(sql)
  
      sql = 'INSERT INTO a(apply,ip) VALUES(%s,%s)'
  
      #param = [['tomcat', '192.1.1.121'], ['redis', '192.1.1.122'], ['mongodb', '192.1.1.122']]
  
      #param = ((username1, salt1, pwd1), (username2, salt2, pwd2), (username3, salt3, pwd3))
  
      cur.executemany(sql, param)
  
      '''
  
      sql_lines = []
  
      with open('1.txt', 'r') as file:
  
            for lines in file.readlines():
  
                line = lines.strip('\n').split()
  
                sql = 'insert a(ip,yy) values({0});'.format(line)
  
                sql_lines.append(sql)
  

  
      sql_last = '\r\n'.join(sql_lines)
  
      cur.execute(sql_last)
  
      # cur.execute("INSERT INTO Writers(Name) VALUES('Honore de Balzac')")
  
      # cur.execute("INSERT INTO Writers(Name) VALUES('Lion Feuchtwanger')")
  
      # cur.execute("INSERT INTO Writers(Name) VALUES('Emile Zola')")
  
      # cur.execute("INSERT INTO Writers(Name) VALUES('Truman Capote')")
  
      '''
  

  
def db_execute(sql):
  
    cursor = con.cursor()
  
    cursor.execute(sql)
  
    cursor.close()
  
def read_file(file_path):
  
    sql_lines = []
  
    with open(file_path, 'r') as file:
  
      for lines in file.readlines():
  
            line = lines.strip('\n').split()
  
            # sql = 'insert table(field) values({0});'.format(line)
  
            sql_lines.append(line)
  
    print sql_lines
  
    return sql_lines
  

  
    # print '\r\n'.join(str(sql_lines)) python3用的
  

  
sql_lines = read_file('1.txt')
  
# db_execute(sql_lines)
  
test1=test(sql_lines)
  
# test1=test()
页: [1]
查看完整版本: python2.7 MySQLdb insert