一個初學者的辛酸路程-python操作SQLAlchemy-13

前言

　　其實一開始寫blog，我是拒絕的，但是，沒辦法，沒有任何理由抗拒。今天呢，要說的就是如何使用Python來操作數據庫。

SQLAlchemy

SQLAlchemy是Python編程語言下的一款ORM框架，該框架建立在數據庫API智商，使用關系對象映射進行數據庫操作，換句話說就是：將對象轉換成SQL，然后使用數據API執行SQL語句並獲取到執行結果。

以前我們常用pymysql來操作數據庫，舉個栗子

（需要提前安裝上pymysql）

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# Author: Leon xie

import  pymysql

#創建連接
conn = pymysql.connect(host='192.168.56.11',port=3306,user='root',passwd='root',db='oldboydb')
#創建游標  socket上建立的實例
cursor=conn.cursor()

#執行SQL，並返回行數,用游標執行，
effect_row = cursor.execute("select * from student")
# print(cursor.fetchone())
# print(cursor.fetchone())
print(cursor.fetchall())

這樣就可以把數據全部取出來。

插入數據呢？

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# Author: Leon xie

import  pymysql

#創建連接
conn = pymysql.connect(host='192.168.56.11',port=3306,user='root',passwd='root',db='oldboydb')
#創建游標  socket上建立的實例
cursor=conn.cursor()

#執行SQL，並返回行數,用游標執行，
#effect_row = cursor.execute("select * from student")
# print(cursor.fetchone())
# print(cursor.fetchone())
# print(cursor.fetchall())

data = [
    ("N1","2015-05-22",'M'),
    ("N2","2015-05-22",'M'),
    ("N3","2015-05-22",'M'),
    ("N4","2015-05-22",'M'),
]

cursor.executemany("insert into student (name,register_date,gender) values(%s,%s,%s)",data )

conn.commit()

有個問題，上面需要我寫原生的SQL語句來使用。如果寫原生，自己增刪改，如果簡單還行，復雜就很麻煩了，重用性不強，因為都是寫死在里面，如果數據庫結果變化就的改，對擴展什么都不方便，包括

SQL水平也就一般般，很多情況寫不出高效的SQL語句，涉及到軟件好慢好慢，加機器都不好使。

為了避免，我們把原生SQL寫死到源代碼里，怎么辦呢？就要引入下面的東西。

SQLAlchemy是python編程語言下的一款ORM框架，該框架建立在數據庫API之上，使用關系對象映射進行數據庫操作。簡言之便是：將對象轉換成SQL，然后使用數據API執行SQL並獲取執行結果。

這樣，就不用寫原生的SQL了。

所以我們引入了ORM，什么是ORM？

ORM就是對象映射關系程序。 相當於ORM幫我們把對象里的轉化成SQL然后跟數據庫交互

ORM的優點：

1、隱藏了數據訪問細節，封閉的通用數據庫交互，ORM的核心，它使得我們的通用數據庫交互變得簡單易行，並且完全不用考慮該死的SQL語句。快速開發，由此而來。

2、ORM使我們構造固化數據結構變得簡單易行。

缺點：

1、無可避免，自動化意味着映射和關聯管理，代價是犧牲性能

ORM是一個術語，不是一個軟件，基於ORM的標准下，有很多軟件，最執行的就是SQLAlchemy ，（SQL 阿哥迷）

如何使用？

windows下安裝

pip install sqlalchemy

 

接下來利用ORM實現一個創建表的功能

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# Author: Leon xie

import sqlalchemy

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column,Integer,String

engine = create_engine("mysql+pymysql://root:root@192.168.56.11/oldboydb",encoding='utf-8',echo=True)
#echo=True，就是把整個過程打印出來
Base=declarative_base() #生成ORM基類

class User(Base):
    __tablename__ = 'user' #表名
    id = Column(Integer,primary_key=True) #字段，整形，主鍵 column是導入的
    name = Column(String(32))
    password = Column(String(64))

Base.metadata.create_all(engine) #創建表結構

實現結果，就是在數據庫創建了一個表，user，再次執行，如果數據庫有，它就不會創建了。

 

插入數據

'''
創建數據，有個游標的東西叫做sessionmaker需要單獨導入
'''

#實例與socket綁定,創建與數據庫的繪畫session class，注意，這里返回
#給session的是一個class，不是實例
Session_class = sessionmaker(bind=engine)
#生成session實例，cursor
Session = Session_class()

#生產你要創建的數據對象
xiedi_obj = User(name="alex",password="123")
xiedi_obj2 = User(name="jack",password="123")
#目前還沒有創建對象，可以打印看看，上面只是申明
print(xiedi_obj.name,xiedi_obj.id)

#把要創建的數據對象添加到這個session里，一會同一創建
Session.add(xiedi_obj)
Session.add(xiedi_obj2)
#這里依舊沒有創建
print(xiedi_obj.name,xiedi_obj.id)

#現在才同一提交，創建數據
Session.commit()

查詢

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# Author: Leon xie

'''
利用ORM實現一個創建表的功能
'''
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:root@192.168.56.11/oldboydb",encoding='utf-8')
Base = declarative_base()  #生成ORM基類
#創建表結構
class User(Base):
    __tablename__ = 'xiedi' #表名
    id = Column(Integer,primary_key=True)
    name = Column(String(32))
    password = Column(String(64))

    def __repr__(self):
        return "<%s name:%s>" % (self.id,self.name)

#直接調用基類下的方法，創建表結構
Base.metadata.create_all(engine)
'''
查看
'''
T1 = sessionmaker(bind=engine)
T2 = T1()
#filter查出來的是一組數據，它不知道你要查多少
data = T2.query(User).filter_by().all()
print(data)

打印結果

[<1 name:alex>, <2 name:jack>]

修改，原理就是搜索出來，然后賦值

data = Session.query(User).filter(User.id>1).filter(User.id<4).first()
print(data)
data.name = "Jack Liu"
data.password = "Shit happens"
#提交
Session.commit()

 

統計

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# Author: Leon xie

'''
利用ORM實現一個創建表的功能
'''

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:root@192.168.56.11/oldboydb",encoding='utf-8')
Base = declarative_base()  #生成ORM基類

#創建表結構
class User(Base):
    __tablename__ = 'xiedi' #表名
    id = Column(Integer,primary_key=True)
    name = Column(String(32))
    password = Column(String(64))

#直接調用基類下的方法
Base.metadata.create_all(engine)

#實例與socket綁定,創建與數據庫的繪畫session class，注意，這里返回
#給session的是一個class，不是實例
Session_class = sessionmaker(bind=engine)
#生成session實例，cursor
Session = Session_class()

#創建用戶
fake_user = User(name='rain',password="12345")
Session.add(fake_user)

print(Session.query(User).filter(User.name.in_(['xiedi','rain','jack'])).all())

Session.rollback()
print(Session.query(User).filter(User.name.in_(['xiedi','rain','jack'])).all())

print(Session.query(User).filter(User.name.in_(['Jack','rain'])).count())
打印結果
1

 

那么如何取分組呢？統計每個名字出現多少次

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# Author: Leon xie

'''
利用ORM實現一個創建表的功能
'''
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:root@192.168.56.11/oldboydb",encoding='utf-8')
Base = declarative_base()  #生成ORM基類
#創建表結構
class User(Base):
    __tablename__ = 'xiedi' #表名
    id = Column(Integer,primary_key=True)
    name = Column(String(32))
    password = Column(String(64))
#直接調用基類下的方法，創建表結構
Base.metadata.create_all(engine)

'''
創建數據，有個游標的東西叫做sessionmaker需要單獨導入
'''

#實例與socket綁定,創建與數據庫的繪畫session class，注意，這里返回
#給session的是一個class，不是實例
Session_class = sessionmaker(bind=engine)
#生成session實例，cursor
Session = Session_class()

from sqlalchemy import func

print(Session.query(User.name,func.count(User.name)).group_by(User.name).all())
打印結果
[('alex', 1, 'alex'), ('Jack Liu', 1, 'Jack Liu')]

 

外鍵關聯

#!/usr/bin/env python
# -*- coding:utf-8 -*-
# Author: Leon xie

import sqlalchemy

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column,Integer,String,DATE,Enum
from sqlalchemy.orm import sessionmaker

engine = create_engine("mysql+pymysql://root:root@192.168.56.11/oldboydb",encoding='utf-8')
#echo=True，就是把整個過程打印出來
Base=declarative_base() #生成ORM基類
class User(Base):
    __tablename__ = 'user' #表名
    id = Column(Integer,primary_key=True) #字段，整形，主鍵 column是導入的
    name = Column(String(32))
    password = Column(String(64))

    def __repr__(self):
        return "<%s name:%s>" % (self.id,self.name)

class Student(Base):
    __tablename__ = 'student' #表名
    id = Column(Integer,primary_key=True) #字段，整形，主鍵 column是導入的
    name = Column(String(32),nullable=False)
    register_date = Column(DATE,nullable=False)
    gender = Column(String(32),nullable=False)

    def __repr__(self):
        return "<%s name:%s>" % (self.id,self.name)

Base.metadata.create_all(engine) #創建表結構

Session_class = sessionmaker(bind=engine)
Session = Session_class()

# s1 = Student(name="s2",register_date="2015-03-01",gender="F")
# Session.add(s1)

print(Session.query(User,Student).filter(User.id==Student.id).all())
Session.commit()