SQLAlchemy
SQLAlchemy是Python编程语言下的一款ORM框架,该框架建立在数据库API之上,使用关系对象映射进行数据库操作,简言之便是:将对象转换成SQL,然后使用数据API执行SQL并获取执行结果。
对象映射关系(ORM)
orm英文全称object relational mapping,就是对象映射关系程序,简单来说我们类似python这种面向对象的程序来说一切皆对象,但是我们使用的数据库却都是关系型的,为了保证一致的使用习惯,通过orm将编程语言的对象模型和数据库的关系模型建立映射关系,这样我们在使用编程语言对数据库进行操作的时候可以直接使用编程语言的对象模型进行操作就可以了,而不用直接使用sql语言
优点:
缺点:
sqlalchemy安装
Dialect用于和数据API进行交流,根据配置文件的不同调用不同的数据库API,从而实现对数据库的操作,如:
MySQL-Python mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname> pymysql mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>] MySQL-Connector mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname> cx_Oracle oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...] 更多详见:http://docs.sqlalchemy.org/en/latest/dialects/index.html
注:支持连接MySQL、Oracles数据库
安装:
pip install SQLAlchemy pip install pymysql #由于mysqldb依然不支持py3,所以这里我们用pymysql与sqlalchemy交互
基本使用
创建表结构
#!/usr/bin/env python # -*- coding: UTF-8 -*- import sqlalchemy from sqlalchemy import create_engine from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import Column, Integer, String from sqlalchemy.orm import sessionmaker engine = create_engine("mysql+pymysql://root@192.168.91.92/sxl", encoding="utf-8", echo=True) # echo=True 打印程序运行详细信息 Base = declarative_base() # 生成orm基类 class User(Base): __tablename__ = "user" # 表名 id = Column(Integer, primary_key=True) name = Column(String(32)) password = Column(String(64)) class color(Base): __tablename__ = "color" # 表名 id = Column(Integer, primary_key=True) name = Column(String(32)) password = Column(String(64)) Base.metadata.create_all(engine)
创建数据
最基本的表我们创建好了,那我们开始用orm创建一条数据试试
from sqlalchemy import create_engine from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import String,Integer,Column from sqlalchemy.orm import sessionmaker engine = create_engine("mysql+pymysql://root@192.168.91.92/sxl", encoding="utf-8") Base = declarative_base() #生成orm基类 class User(Base): __tablename__ = "user" #表名 id = Column(Integer,primary_key=True) name = Column(String(32)) password = Column(String(64)) #Base.metadata.create_all(engine) #创建表结构 Session_class = sessionmaker(bind=engine) #Session_class现在不是实例,而是类 Session = Session_class() #生成Session实例 user_obj = User(name="sxl",password="123") #生成你要创建的数据对象 print(user_obj.name,user_obj.id) #此时还没创建对象呢,不信你打印一下id发现还是None Session.add(user_obj) #把要创建的数据对象添加到这个session里, 一会统一创建 print(user_obj.name,user_obj.id) #此时也依然还没创建 Session.commit() #现此才统一提交,创建数据
增删改查
from sqlalchemy import create_engine from sqlalchemy.ext.declarative import declarative_base from sqlalchemy import String,Integer,Column from sqlalchemy.orm import sessionmaker engine = create_engine("mysql+pymysql://root@192.168.91.92/sxl", encoding="utf-8") Base = declarative_base() #生成orm基类 class User(Base): __tablename__ = "user" #表名 id = Column(Integer,primary_key=True) name = Column(String(32)) password = Column(String(64)) #Base.metadata.create_all(engine) #创建表结构 Session_class = sessionmaker(bind=engine) #Session_class现在不是实例,而是类 Session = Session_class() #生成Session实例
#添加数据 user_obj = User(name="sxl",password="123") #生成你要创建的数据对象 Session.add(user_obj) #把要创建的数据对象添加到这个session里, 一会统一创建 Session.commit() #现此才统一提交,创建数据
#查询数据
myuser=Session.query(color).filter(color.password==‘123‘).first()
print(myuser) #myuser现在是一个对象
print(myuser.id,myuser.name,myuser.password)
#修改数据
myuser.name=‘abc‘
Session.commit()
#删除数据
Session.delete(myuser)
Session.commit()
原文:http://www.cnblogs.com/sxlnnnn/p/6397579.html