当前位置： 移动技术网 > IT编程>脚本编程>Python > SQLAlchemy简介

SQLAlchemy简介

2019年06月25日  | 移动技术网IT编程  | 我要评论

巨魔战将出装,仁怀论坛,植物操纵者

一、sqlalchemy简介

sqlalchemy是python sql工具包和对象关系映射器，是python中最著名的orm(object relationship mapping)框架，它简化了应用程序开发人员在原生sql上的操作，使开发人员将主要精力都放在程序逻辑上，从而提高开发效率。它提供了一整套著名的企业级持久性模式，设计用于高效和高性能的数据库访问。
使用orm操作数据库：
优势 ：代码易读，隐藏底层原生sql语句，提高了开发效率。
劣势 ：执行效率低 ，将方法转换为原生sql后 原生sql不一定是最优的。

环境：

windows 7  x64   python 3.7.1  sqlalchemy 1.3.5   pymysql 0.9.3    mysqld  5.6.43

关于如何安装上述环境，这里不做演示，相信大家能搜到这篇文章，想必这种小问题不在话下。

二、简单的操作

1、准备数据库sql_demo

mysql> create database sql_demo;

2、在sql_demo中创建表

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import column, integer, string
from sqlalchemy import create_engine

base = declarative_base()  # 导出官方基础类

class sqldemo(base):
    __tablename__ = 'sqldemo'  # 表名
    # 创建字段
    id = column(integer,primary_key=true,autoincrement=true)
    name = column(string(32))

# 创建数据库引擎
engine = create_engine('mysql+pymysql://数据库用户:数据库密码@127.0.0.1:3306/数据库名?charset=utf8')
# 创建表
base.metadata.create_all(engine)

运行上面的代码后会在数据库sql_demo中创建一个名为sqldemo的表。

 3、向表中添加数据。

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import column, integer, string
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
base = declarative_base()  # 导出官方基础类

class sqldemo(base):
    __tablename__ = 'sqldemo'  # 表名
    # 创建字段
    id = column(integer,primary_key=true,autoincrement=true)
    name = column(string(32))

# 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建表
# base.metadata.create_all(engine)
# 向表中添加数据
obj = sqldemo(name='小明')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 向表中添加数据,此时数据保存在内存中
db_session.add(obj)
# 提交数据，将数据保存到数据库中
db_session.commit()
# 关闭会话
db_session.close()

 3.1向表中添加多条数据。

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import column, integer, string
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
base = declarative_base()  # 导出官方基础类

class sqldemo(base):
    __tablename__ = 'sqldemo'  # 表名
    # 创建字段
    id = column(integer,primary_key=true,autoincrement=true)
    name = column(string(32))

# # 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# # 创建表
# base.metadata.create_all(engine)
# 添加多条数据
obj = [
    sqldemo(name='小红'),
    sqldemo(name='小刚'),
    sqldemo(name='小虎'),
    ]
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 向表中添加数据,此时数据保存在内存中
db_session.add_all(obj)
# 提交数据，将数据保存到数据库中
db_session.commit()

 添加后的数据如下：

 4、查询表中数据

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import column, integer, string
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
base = declarative_base()  # 导出官方基础类

class sqldemo(base):
    __tablename__ = 'sqldemo'  # 表名
    # 创建字段
    id = column(integer,primary_key=true,autoincrement=true)
    name = column(string(32))

# # 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 查询表中所有数据
all_list = db_session.query(sqldemo).all()
for obj in all_list:
    print(obj.id,obj.name)
# 提交数据，将数据保存到数据库中
db_session.commit()
# 关闭会话
db_session.close()

 最终打印结果如下：

 4.1使用filter过滤查询条件

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import column, integer, string
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
base = declarative_base()  # 导出官方基础类

class sqldemo(base):
    __tablename__ = 'sqldemo'  # 表名
    # 创建字段
    id = column(integer,primary_key=true,autoincrement=true)
    name = column(string(32))

# # 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 使用filter过滤查询条件
all_list = db_session.query(sqldemo).filter(sqldemo.name=='小明')
for obj in all_list:
    print(obj.id,obj.name)
# 提交数据，将数据保存到数据库中
db_session.commit()
# 关闭会话

 

5、 修改数据

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import column, integer, string
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
base = declarative_base()  # 导出官方基础类

class sqldemo(base):
    __tablename__ = 'sqldemo'  # 表名
    # 创建字段
    id = column(integer,primary_key=true,autoincrement=true)
    name = column(string(32))

# 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 更改id是2的name为娃哈哈
all_list = db_session.query(sqldemo).filter(sqldemo.id==2).update({'name':'娃哈哈'})
# 提交数据，将数据保存到数据库中
db_session.commit()
# 关闭会话
db_session.close()

 6、删除数据

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import column, integer, string
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
base = declarative_base()  # 导出官方基础类

class sqldemo(base):
    __tablename__ = 'sqldemo'  # 表名
    # 创建字段
    id = column(integer,primary_key=true,autoincrement=true)
    name = column(string(32))

# # 创建数据库引擎
engine = create_engine('mysql+pymysql://root:123@127.0.0.1:3306/sql_demo?charset=utf8')
# 创建会话
obj_session = sessionmaker(engine)
# 打开会话
db_session = obj_session()
# 删除id是2的行
all_list = db_session.query(sqldemo).filter(sqldemo.id==2).delete()
# 提交数据，将数据保存到数据库中
db_session.commit()
# 关闭会话
db_session.close()

 好了sqlalchemy先简单介绍这里，关于sqlalchemy的一些高级操作待更新。。。。。

 

您可能感兴趣的文章:

如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网