1.操作mysql代码;
import MySQLdb
def get_conn():
host = "127.0.0.1"
port = 3306
db = "python"
user = "root"
password = "123456"
conn = MySQLdb.connect(host=host,user=user,password=password,db=db,port=port,charset="utf8")
return conn
class User(object):
def __init__(self,user_id,user_name):
self.user_id = user_id
self.user_name = user_name
def save(self):
conn = get_conn()
cursor = conn.cursor()
sql = "insert into user (user_id,user_name) VALUES (%s,%s)"
cursor.execute(sql.user_id,self.user_name)
conn.commit()
cursor.close()
conn.close()
@staticmethod
def query_all():
conn = get_conn()
cursor = conn.crusor()
sql = "select * from user"
cursor.execute(sql)
rows = cursor.fetchall()
users= []
for i in rows:
user = User(r[0], r[i])
users.append(user)
conn.commit()
cursor.close()
conn.close()
return users
def __str__(self):
return "id:{}-name:{}".format(self.user_id,self.user_name)
2.调用方法;
#endcoding=utf-8
from flask_script import Manager
from app import app
from models import User
manager = Manager(app)
@manager.command
def save():
user = User(1,'breaklinux_project')
user.save()
@manager.command
def query_all():
users = User.query_all()
for u in users:
print u
if __name__ == '__main__':
manager.run()
python 操作mysql
原文：http://blog.51cto.com/breaklinux/2130203
