Sqlalchemy使用连接Mysql/Pgsql，并用Orm和原生Sql增删改查

注意创建表的时候，Pgsql不要创建User表，因为User表是Pgsql的关键字，会出错。

Flask-SQLAlchemy

Flask-SQLAlchemy库让flask更方便的使用SQLALchemy,是一个强大的关系形数据库框架,既可以使用orm方式操作数据库,也可以使用原始的SQL命令.

需要安装的包

MySQL

SQLAlchemy

Flask-SQLAlchemy

mysqlclient

配置Flask-SQLAlchemy

示例：

MySQL:  mysql://username:password@hostname/database

PgSql：postgresql://用户名:密码@localhost:8891/pgdbname

 数据库创建和配置：

1.  
   create table Users
2.  
   (
3.  
   id serial primary key,
4.  
   nick_name varchar(255)
5.  
   );

随便增加一条数据就可以了。 

1.  
   from sqlalchemy import Column, Integer, MetaData, VARCHAR
2.  
   from flask_sqlalchemy import SQLAlchemy
3.  
   from flask import Flask
4.  
    
5.  
   app = Flask(__name__)
6.  
    
7.  
   #配置数据库地址Mysql：
8.  
   app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:wjjf2008@127.0.0.1:3306/internet_plus?charset=utf8'
9.  
    
10.  
    #Pgsql配置： SQLALCHEMY_DATABASE_URI = "postgresql://postgres:postgres@localhost:8891/pgdbname"
11.  
    #该配置为True,则每次请求结束都会自动commit数据库的变动
12.  
    app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
13.  
     
14.  
    db = SQLAlchemy(app)
15.  
    #也可以db = SQLAlchemy() db.init_app(app)
16.  
     
17.  
     
18.  
     
19.  
    class User(db.Model):
20.  
    """用户"""
21.  
    __tablename__ = "User"
22.  
    id = db.Column(db.Integer, primary_key=True) # 用户编号
23.  
    nick_name = db.Column(db.String(32), unique=True, nullable=False) # 用户昵称
24.  
     
25.  
    def __repr__(self):
26.  
    """
27.  
    格式化输出
28.  
    """
29.  
    return '<User %r>' % self.nick_name
30.  
     
31.  
    def to_json(self):
32.  
    """
33.  
    为了转json提供的方法
34.  
    """
35.  
    dict = self.__dict__
36.  
    if "_sa_instance_state" in dict:
37.  
    del dict["_sa_instance_state"]
38.  
    return dict
39.  
     
40.  
    @app.route("/add_user")
41.  
    def add_user():
42.  
    # 添加测试数据库
43.  
    u = User()
44.  
    u.nick_name = "wang"
45.  
    # 将用户添加到数据库会话中
46.  
    db.session.add(u)
47.  
    # 将数据库会话中的变动提交到数据库中,如果不Commit,数据库中是没有改动的
48.  
    db.session.commit()
49.  
    return "添加成功"
50.  
     
51.  
     
52.  
    @app.route("/query_user")
53.  
    def query_user():
54.  
    # 返回所有用户保存到list中
55.  
    user_list = User.query.all()
56.  
    print(user_list)
57.  
    # 转成Json返回
58.  
    result = [u.to_json() for u in user_list]
59.  
    return jsonify(result), 200
60.  
     
61.  
     
62.  
    @app.route("/exec_sql")
63.  
    def exec_sql():
64.  
    # 执行原生SQL
65.  
    res = db.session.execute('select * from "User";').fetchall()
66.  
    emp_json_list = [dict(zip(item.keys(), item)) for item in res]
67.  
    print(emp_json_list)
68.  
    return jsonify(emp_json_list), 200
69.  
     
70.  
     
71.  
    if __name__ == '__main__':
72.  
    # db.create_all() #创建数据库
73.  
    app.run(host="0.0.0.0", port=5000)

 直接访问：

这篇好文章是转载于：学新通技术网