SQLAlchemy簡(jiǎn)單入門

SQlAlchemy簡(jiǎn)單使用

sqlalchemy介紹

SQLAlchemy的是Python的SQL工具包和對(duì)象關(guān)系映射器，讓應(yīng)用程序開發(fā)人員可以使用上SQL的強(qiáng)大功能和靈活性。
它提供了一套完整的企業(yè)級(jí)持久化模式，專為高效率和高性能的數(shù)據(jù)庫(kù)訪問(wèn)而設(shè)計(jì)，簡(jiǎn)單易用用，專門為Python語(yǔ)言而準(zhǔn)備。

SQLAlchemy的理念

SQL數(shù)據(jù)庫(kù)與對(duì)象集合目標(biāo)不同，它需要關(guān)注更大的數(shù)據(jù)容量與更高的性能;而對(duì)象集合則和數(shù)據(jù)表或數(shù)據(jù)行的目標(biāo)不同，它需要更好的數(shù)據(jù)抽象。 SQLAlchemy設(shè)計(jì)的目的，就是適配這兩個(gè)原則。

SQLAlchemy把數(shù)據(jù)庫(kù)當(dāng)作是一個(gè)關(guān)系型代數(shù)引擎，不只是數(shù)據(jù)表的一個(gè)集合。數(shù)據(jù)行不僅可以從數(shù)據(jù)表中查詢出來(lái)，也可以從數(shù)據(jù)表關(guān)聯(lián)后成形成的邏輯數(shù)據(jù)表和其他的查詢語(yǔ)句結(jié)果中進(jìn)行查詢;這些元素可以組合形成更大的數(shù)據(jù)結(jié)構(gòu)。 SQLAlchemy的表達(dá)式語(yǔ)言就是建立在這個(gè)核心概念之上的。

SQLAlchemy組件中最有名的是它的對(duì)象關(guān)系映射器（ORM），是一個(gè)提供數(shù)據(jù)映射器模式的可選組件，利用這個(gè)組件，類可以以開放式的多種方式映射到數(shù)據(jù)庫(kù)上，允許對(duì)象模型的設(shè)計(jì)和數(shù)據(jù)庫(kù)架構(gòu)的設(shè)計(jì)，一開始就以分離方式進(jìn)行各自的開發(fā)。實(shí)現(xiàn)松耦合的架構(gòu).

sqlalchemgy文檔

獨(dú)處
連接數(shù)據(jù)庫(kù)
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker


DB_CONNECT_STRING = 'mysql+mysqldb://root:123@localhost/mydb?charset=utf8'
engine = create_engine(DB_CONNECT_STRING)
DB_Session = sessionmaker(bind=engine)
session = DB_Session()

上面的DB_CONNECT_STRING是連接數(shù)據(jù)庫(kù)的路徑,這個(gè)路徑也就是database_urls包含了使用的數(shù)據(jù)庫(kù)驅(qū)動(dòng)以及數(shù)據(jù)庫(kù)的連接信息等.一般格式是:dialect+driver://username:password@host:port/database
下面給出其他形式的數(shù)據(jù)庫(kù)連接示例:

# default
engine = create_engine('postgresql://scott:tiger@localhost/mydatabase')

# psycopg2
engine = create_engine('postgresql+psycopg2://scott:tiger@localhost/mydatabase')

# pg8000
engine = create_engine('postgresql+pg8000://scott:tiger@localhost/mydatabase')


# default
engine = create_engine('mysql://scott:tiger@localhost/foo')

# mysql-python
engine = create_engine('mysql+mysqldb://scott:tiger@localhost/foo')

# MySQL-connector-python
engine = create_engine('mysql+mysqlconnector://scott:tiger@localhost/foo')

# OurSQL
engine = create_engine('mysql+oursql://scott:tiger@localhost/foo')
直接操作sql
sql= 'show tables'
session.execute(sql)
result = session.excute(sql).fetchall()

sql = 'create database test'
session.excute(sql)

以上使用sqlalchemy直接執(zhí)行sql語(yǔ)句,這和mysql-python沒有任何區(qū)別.當(dāng)然,需要注意在事務(wù)操作中,記得commit.在操作很復(fù)雜的sql語(yǔ)句,不能映射到對(duì)應(yīng)的ORM上,這是備用選項(xiàng).

下面開始介紹sqlalchemy的ORM.從數(shù)據(jù)庫(kù)的增刪查改.

關(guān)聯(lián)一個(gè)數(shù)據(jù)表
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, String, Integer

engine = create_engine('mysql+mysqldb://root:youdi@localhost:3306/alchemy?charset=utf8')
Base = declarative_base()

class User(Base):

    __tablename__ = 'users'

    id = Column(Integer, primary_key=True)
    name = Column('username',String(64), nullable=False)
    password = Column(String(64), nullable=False)

    email = Column(String(64), nullable=False)

    def __repr__(self):
        return '%s(%r)' % (self.__class__.__name__, self.username)
插入數(shù)據(jù)
import User
from sqlalchemy.orm import sessionmaker
session = sessionmaker(bind=engine)
mysql = session()

user1 = User()
user1.id = 2
user1.name = 'hello'
user1.email = '123@gmail.net'
user1.password = 'password'

mysql.add(user1)

user2 = User(id=3,name='youmi',password='1234',email='12@you.net')

mysql.add(user2)

mysql.commit()

上面插入了兩條數(shù)據(jù)

mysql> select * from users;
+----+----------+----------+---------------+
| id | username | password | email         |
+----+----------+----------+---------------+
|  2 | hello    | password | 123@gmail.net |
|  3 | youmi    | 1234     | 12@you.net    |
+----+----------+----------+---------------+
2 rows in set (0.02 sec)

查詢表中的數(shù)據(jù)

1.查詢所有的數(shù)據(jù)

如同select * from tb_name

query = mysql.query(User)
sql = str(query) # 執(zhí)行的sql語(yǔ)句
sql = query.statement # 執(zhí)行的sql語(yǔ)句

users_name = []
for i in query:  #遍歷時(shí)查詢
    users_name.append(i.name)

query.all() #返回所有對(duì)象的列表
query.first() #返回第一個(gè)對(duì)象,記錄不存在時(shí)，first() 會(huì)返回 None
query.one()  # 不存在，或有多行記錄時(shí)會(huì)拋出異常

另外,query也可以使用User直接獲得
query = User.query
2.顯示指定字段的數(shù)據(jù)

如同: select name,id from users

names = mysql.query(User.name)
names.all() #每行都是一個(gè)元組
3.篩選條件

limit

mysql.query(User).limit(10)
User.query.limit(10)

offset

offset = 10
mysql.query(User).offset(offset).limit(10)
# or
User.query.offset(offset).limit(10)

oder by

mysql.query(User).order_by('id')
mysql.query(User).order_by(User.id.desc())
mysql.query(User).order_by('id asc')
mysql.query(User).order_by(User.name.desc(),User.id)

filter
sql中的where后面的條件

mysql.query(User).filter(User.id == 1).scalar()
# or 使用字面量
mysql.query(User).filter('id = 1').scalar()
# 多個(gè)條件
mysql.query(User).filter(User.id > 1,User.name != 'youmi').scalar()
# in條件
mysql.query(User).filter(User.id.in_((1,2,3))).scalar()

# or條件需要導(dǎo)入or_()函數(shù)
mysql.query(User).filter(or_(User.id > 1,User.name != 'youmi')).scalar()

補(bǔ)充(所有的額外函數(shù)):
其中func映射到sql中的很多函數(shù),如:count,sum,now,current_timestamp,md5等等,
其他的函數(shù),有case對(duì)應(yīng)sql中when case

from .sql import (
    alias,
    and_,
    asc,
    between,
    bindparam,
    case,
    cast,
    collate,
    delete,
    desc,
    distinct,
    except_,
    except_all,
    exists,
    extract,
    false,
    func,
    insert,
    intersect,
    intersect_all,
    join,
    literal,
    literal_column,
    modifier,
    not_,
    null,
    or_,
    outerjoin,
    outparam,
    over,
    select,
    subquery,
    text,
    true,
    tuple_,
    type_coerce,
    union,
    union_all,
    update,
    )
4.聯(lián)表查詢(join)

INNER JOIN

query = User.query.join(Group, User.gid == Group.id)
.filter(User.id != None,"is_superuser & 1 = 1")
.order_by(User.last_edit.asc()).limit(10)

LEFT JOIN

query = User.query.outerjoin(Group, User.gid == Group.id)
.filter(User.id != None,"is_superuser & 1 = 1")
.order_by(User.last_edit.asc()).limit(10)

RIGHT JOIN

query = User.query.outerjoin(Group, User.gid == Group.id)
.filter(User.id != None,"is_superuser & 1 = 1")
.order_by(User.last_edit.asc()).limit(10)

其他的連接方式,需要自己指定參數(shù),可以靈活的操作:

    def join(self, right, onclause=None, isouter=False, join_to_left=None):
        return _ORMJoin(self, right, onclause, isouter)

    def outerjoin(self, right, onclause=None, join_to_left=None):
        return _ORMJoin(self, right, onclause, True)

修改數(shù)據(jù)

mysql.query(User).filter(User.id == 1).update({User.name:'youmi'})

# or 
user = mysql.query(User).filter(User.id == 1)
user.name = 'test'
mysql.flush() #寫入數(shù)據(jù)庫(kù),但并沒有提交

刪除數(shù)據(jù)

mysql.query(User).filter(User.id == 1).delete()
mysql.commit()
心 * 自由

不過(guò)相比Django的ORM.sqlalchemy對(duì)sql的支持更好.
上面只是簡(jiǎn)單的介紹了sqlalchemy的增刪查改,需要更加深入的特性,可以查看官方文檔,或者查看源碼.

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡(jiǎn)書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • 轉(zhuǎn)載，覺得這篇寫 SQLAlchemy Core，寫得非常不錯(cuò)。不過(guò)后續(xù)他沒寫SQLAlchemy ORM... ...
    非夢(mèng)nj閱讀 5,597評(píng)論 1贊 14
  • URL與視圖 URL與函數(shù)的映射： 從之前的helloworld.py文件中，我們已經(jīng)看到，一個(gè)URL要與執(zhí)行函數(shù)...
    編程小蟬閱讀 2,830評(píng)論 1贊 19
  • 1. Java基礎(chǔ)部分 基礎(chǔ)部分的順序：基本語(yǔ)法，類相關(guān)的語(yǔ)法，內(nèi)部類的語(yǔ)法，繼承相關(guān)的語(yǔ)法，異常的語(yǔ)法，線程的語(yǔ)...
    子非魚_t_閱讀 34,641評(píng)論 18贊 399
  • <魔神相克者>；（本作原名） アスラクレイン ，Asura Cryin'， Asura就是印度教神話中的阿修羅，是...
    空白_7閱讀 1,242評(píng)論 0贊 0
  • 羈羈絆羈羈，朝朝辭舊夕。 人人偎人人，雙雙入紅塵。
    不如喫茶去閱讀 215評(píng)論 0贊 0

友情鏈接更多精彩內(nèi)容