本教材由知了传课辛苦制作而成，仅供学习使用，请勿用于商业用途！如进行转载请务必注明出处！谢谢！

SQLAlchemy介绍

一、安装：

SQLAlchemy是一个数据库的ORM框架，让我们操作数据库的时候不要再用SQL语句了，跟直接操作模型一样。安装命令为：pip install SQLAlchemy。

二、通过`SQLAlchemy`连接数据库：

首先来看一段代码：

from sqlalchemy import create_engine

# 数据库的配置变量
HOSTNAME = '127.0.0.1'
PORT     = '3306'
DATABASE = 'xt_flask'
USERNAME = 'root'
PASSWORD = 'root'
DB_URI = 'mysql+pymysql://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)

# 创建数据库引擎
engine = create_engine(DB_URI)

#创建连接
with engine.connect() as con:
    rs = con.execute('SELECT 1')
    print rs.fetchone()

首先从sqlalchemy中导入create_engine，用这个函数来创建引擎，然后用engine.connect()来连接数据库。其中一个比较重要的一点是，通过create_engine函数的时候，需要传递一个满足某种格式的字符串，对这个字符串的格式来进行解释：

dialect+driver://username:password@host:port/database?charset=utf8

dialect是数据库的实现，比如MySQL、PostgreSQL、SQLite，并且转换成小写。driver是Python对应的驱动，如果不指定，会选择默认的驱动，比如MySQL的默认驱动是MySQLdb。username是连接数据库的用户名，password是连接数据库的密码，host是连接数据库的域名，port是数据库监听的端口号，database是连接哪个数据库的名字。

如果以上输出了1，说明SQLAlchemy能成功连接到数据库。

二、用SQLAlchemy执行原生SQL：

我们将上一个例子中的数据库配置选项单独放在一个constants.py的文件中，看以下例子：

from sqlalchemy import create_engine
from constants import DB_URI

#连接数据库
engine = create_engine(DB_URI,echo=True)

# 使用with语句连接数据库，如果发生异常会被捕获
with engine.connect() as con:
    # 先删除users表
    con.execute('drop table if exists authors')
    # 创建一个users表，有自增长的id和name
    con.execute('create table authors(id int primary key auto_increment,'name varchar(25))')
    # 插入两条数据到表中
    con.execute('insert into persons(name) values("abc")')
    con.execute('insert into persons(name) values("xiaotuo")')
    # 执行查询操作
    results = con.execute('select * from persons')
    # 从查找的结果中遍历
    for result in results:
        print(result)

11379人已阅读，今天你学习了吗？

9条回复

johndunne2023-05-22 15:19:45

sqlalchemy create_engine
constants DB_URI

engine = create_engine(DB_URI=)

engine.connect() con:
    con.execute()
    con.execute()
    con.execute()
    con.execute()
    results = con.execute()
    result results:
        (result)

1

Denis2022-04-09 12:45:11

con.execute('create table authors(id int primary key auto_increment,'name varchar(25))')
这一句是不是写错了？
1

johndunne2023-05-22 15:20:30

sqlalchemy create_engine
constants DB_URI

engine = create_engine(DB_URI=)

engine.connect() con:
    con.execute()
    con.execute()
    con.execute()
    con.execute()
    results = con.execute()
    result results:
        (result)

leiwang62022-10-25 06:21:58

with engine.connect() as con:
con.execute("drop table if exists authors")
con.execute("CREATE TABLE authors( id serial PRIMARY KEY, username VARCHAR (50) UNIQUE NOT NULL)")

con.execute("INSERT INTO authors(username) values ('abc')")
con.execute("insert into authors(username) values('bcd')")

results = con.execute('select * from authors')
for result in results:
print(result)
leiwang62022-10-25 06:20:24

with engine.connect() as con:
con.execute("drop table if exists authors")
con.execute("CREATE TABLE authors( id serial PRIMARY KEY, username VARCHAR (50) UNIQUE NOT NULL)")

con.execute("INSERT INTO authors(username) values ('abc')")
con.execute("insert into authors(username) values('bcd')")

results = con.execute('select * from account')
for result in results:
print(result)

leiwang62022-10-25 06:19:31

engine.connect() con:
    con.execute()
    con.execute()

    con.execute()
    con.execute()

    results = con.execute()
    result results:
        (result)

wenty11052022-10-24 13:07:05

con.execute('create table authors(id int primary key auto_increment,name varchar(25))')
wenty11052022-10-24 08:47:10

create table authors(id int primary key auto_increment,name varchar(25));
苦行僧2022-05-10 06:43:47

报错了

添加新回复

SQLAlchemy介绍

一、安装：

二、通过SQLAlchemy连接数据库：

二、用SQLAlchemy执行原生SQL：

二、通过`SQLAlchemy`连接数据库：