python 操作mysql

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

相关文章