python mysqlconnetor的使用

1.[代码][Python]代码

# !/usr/bin python

#--*-- coding:utf-8 --*--

import mysql.connector

import os

import codecs

#设置数据库用户名和密码

user='';#用户名

pwd='';#密码

host='';#ip地址

db='';#所要操作数据库名字

charset='UTF-8'

cnx = mysql.connector.connect(user=user,password=pwd, host=host, database=db)

#设置游标

cursor = cnx.cursor()

#query

try:

sql_query='select id,name from test where id > %s'

cursor.execute(sql_query,(21,))

for id,name in cursor:

print ('%s\'s id>21= %d'%(name,id))

# error 执行失败

# stmt='insert into test (id, name) values (%s,%s)'

# data=[

# ('100','Lucy'),

# ('66','Tom'),

# ('52','Lily')]

# cursor.executemany(stmt,data)

except mysql.connector.Error as e:

print('query error!{}'.format(e))

finally:

cursor.close()

cnx.close()

def insert(table_name,insert_dict):

param='';

value='';

if(isinstance(insert_dict,dict)):

for key in insert_dict.keys():

param=param+key+","

value=value+insert_dict[key]+','

param=param[:-1]

value=value[:-1]

sql="insert into %s (%s) values(%s)"%(table_name,param,value)

cursor.execute(sql)

id=cursor.lastrowid

cnx.commit()

return id

#插入数据

#print(insert('test',{'id':'\'101\'','name':'\'michael\''}))