Python使用flask框架操作sqlite3的两种方式

2023-09-17 01:51:05 188

importsqlite3 fromflaskimportFlask,request,jsonify app=Flask(__name__) DATABASE_URI=":memory:" #创建表格、插入数据 @app.before_first_request defcreate_db(): #连接 conn=sqlite3.connect(DATABASE_URI) c=conn.cursor() #创建表 c.execute('''DROPTABLEIFEXISTSuser''') c.execute('''CREATETABLEuser(idINTEGERPRIMARYKEYAUTOINCREMENT,nameTEXT,emailTEXT)''') #数据 #格式：用户名,邮箱 purchases=[('admin','admin@example.com'), ('guest1','guest1@example.com'), ('guest2','guest2@example.com'), ('guest3','guest3@example.com'), ('guest4','guest4@example.com')] #插入数据 c.executemany('INSERTINTOuser(name,email)VALUES(?,?)',purchases) #提交！！！ conn.commit() #关闭 conn.close() defget_db(): db=sqlite3.connect(DATABASE_URI) db.row_factory=sqlite3.Row returndb defquery_db(query,args=(),one=False): db=get_db() cur=db.execute(query,args) db.commit() rv=cur.fetchall() db.close() return(rv[0]ifrvelseNone)ifoneelserv @app.route("/user") defusers(): res=query_db("SELECT*FROMuserWHEREid<=?",args=(6,)) return"
".join(["{0}:{1}".format(user[1],user[2])foruserinres]) @app.route("/user/") defuser(name): res=query_db("SELECT*FROMuserWHEREid=?",args=(id,))#不妨设定：第一次只返回6个数据 returnjsonify(id=res[1], name=res[2], email=res[3])#返回json格式 if__name__=="__main__": app.run(debug=True)

#flask_sqlalchemy.py fromflaskimportFlask fromflask_sqlalchemyimportSQLAlchemy app=Flask(__name__) app.config['SQLALCHEMY_DATABASE_URI']='sqlite://' app.config['SQLALCHEMY_TRACK_MODIFICATIONS']=True db=SQLAlchemy(app) #定义ORM classUser(db.Model): id=db.Column(db.Integer,primary_key=True) name=db.Column(db.String(80),unique=True) email=db.Column(db.String(120),unique=True) def__init__(self,name,email): self.name=name self.email=email def__repr__(self): return''%self.name #创建表格、插入数据 @app.before_first_request defcreate_db(): #Recreatedatabaseeachtimefordemo #db.drop_all() db.create_all() admin=User('admin','admin@example.com') db.session.add(admin) guestes=[User('guest1','guest1@example.com'), User('guest2','guest2@example.com'), User('guest3','guest3@example.com'), User('guest4','guest4@example.com')] db.session.add_all(guestes) db.session.commit() #查询 @app.route('/user') defusers(): users=User.query.all() return"
".join(["{0}:{1}".format(user.name,user.email)foruserinusers]) #查询 @app.route('/user/') defuser(id): user=User.query.filter_by(id=id).one() return"{0}:{1}".format(user.name,user.email) #运行 if__name__=='__main__': app.run('127.0.0.1',5000)

Python使用flask框架操作sqlite3的两种方式

热门推荐

随机推荐