【Python】python读取文件操作mysql

[root@bjdhj-- ~]# python
Python 2.6. (r266:, Feb , ::)
[GCC 4.4. (Red Hat 4.4.-)] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> import MySQLdb
>>>

#-*- coding:utf- -*-
import MySQLdb
from itertools import islice
try:
conn = MySQLdb.connect(host='localhost',user='root',passwd='',port=,charset='utf8')#连接mysqldb
cur = conn.cursor()
conn.select_db('test')
#cur.execute('select max(id) from student')#获取mysql中该表的自增键最大值，向后添加。
#maxid = cur.fetchall()[]
#print 'maxid%id'%maxid
#start = count+
f = file('data2.txt')
list = []
line_num =
for line in islice(f,,None):#读取txt文件，跳过标题行
strs = line.split(",") #文件各字段逗号分隔
line_num = line_num+
print len(strs)
if len(strs)!=: #缺少字段时，跳过该行
print '%d 行缺少字段，请检查文件'%line_num
continue
data = (strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[],strs[].replace("\n","")) #对strs[24]空格进行处理
print data
#start = start+
list.append(data) #将data记录到list中，对list执行插入操作
f.close
cur.executemany('insert into creative_info_test values(%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)',list)
conn.commit() #提交
cur.close()
conn.close()
print 'OK'
except MySQLdb.Error,e:
print "MySQL Error %d:%s"%(e.args[],e.args[])

#-*- coding:utf- -*-
import MySQLdb
conn = MySQLdb.connect(host='localhost',user='root',passwd='',port=,charset='utf8')#连接mysqldb
cur = conn.cursor()
conn.select_db('test')
#逻辑：一次操作只为一次测试使用，所以第一步清除记录；第二步根据条数插入数据；第三个对插入数据进行个性化设置(部分字段的更新)。
try:

Delete()#数据清除
Producer()#将默认数据插入mysql，注意自增主键
Update()#个性化数据更新
conn.commit()#提交
cur.close()
conn.close()
except MySQLdb.Error,e:
print 'MySQL Error %d,%s'%(e.args[0],e.args[1])

#具体实现：插入数据，由于多表插入，切表与表之间有相同字段，所以根据条数做统一设置。
def Producer():
print 'input numbers :'
num = input()#请多写一条
for i in range(,num):
table1['user_id']=i
table2['user_id']=i...
#insert table1
user_info = [user['user_id']...]
cur.execute('insert into user_test values(%s,...)',table1)
#insert table2
...以下类似处理def Update():
print 'input your sql语句 file name:'
filename = raw_input()
f=file(filename)
for line in f.readlines():
operator your sql update #写update语句即可
def Delete():
cur.execute('delete from table1')
cur.execute('delete from table2')
...
#每个表对应一个dict，其字段为字典元素，为各字段设置默认值
table1={
'user_id':'',
'user_name':
...,
}
table2={
...
}

import csv
f = open('creative_info_test.csv','rb')
reader = csv.reader(f)
for row in reader:
print row
f.close