python2.7 MySQLdb insert

hyadijxp

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