python第六十六天--sqlalchemy

来源:http://www.cnblogs.com/uge3/archive/2017/07/07/7132700.html
-Advertisement-
Play Games

1 #!usr/bin/env python 2 #-*-coding:utf-8-*- 3 # Author calmyan 4 #python 5 #2017/7/6 21:29 6 #__author__='Administrator' 7 from sqlalchemy.ext.declar ...


 1 #!usr/bin/env python
 2 #-*-coding:utf-8-*-
 3 # Author calmyan 
 4 #python 
 5 #2017/7/6    21:29
 6 #__author__='Administrator'
 7 from sqlalchemy.ext.declarative import declarative_base
 8 from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index
 9 from sqlalchemy.orm import sessionmaker, relationship
10 from sqlalchemy import create_engine
11 from sqlalchemy import func #統計
12 
13 #                                         用戶 密碼  主機             庫
14 engine = create_engine("mysql+pymysql://root:[email protected]:3306/test",encoding="utf-8",echo=False)
15 
16 Base = declarative_base()#生成orm 基類
17 class User_2(Base):
18     __tablename__='user' #表名
19     id = Column(Integer,primary_key=True)#整數類型  設為主鍵
20     name = Column(String(32))#字元串類型
21     age = Column(Integer)
22     addr= Column(String(256))
23 
24     def __repr__(self):#輸出查詢
25         return '%s>name:%s--age:%saddrs:%s'%(self.id,self.name,self.age,self.addr)
26 
27 
28 Session_class=sessionmaker(bind=engine)#創建與資料庫的會話 類
29 Session=Session_class()#生成實例
30 
31 #增加
32 '''
33 user_obj =User(name="sa2",addrs="1234")#生成你要創建的數據對象
34 Session.add(user_obj)# 添加記錄
35 '''
36 #添加一組數據
37 '''
38 Session.add_all([
39     User(name="abcg",age=34,addr="sdfsdf"),
40     User(name="bcdq",age=11,addr="chaense")
41 ])
42 '''
43 #刪除
44 '''
45 Session.query(User).filter(User.id>3).filter(User.id<6).delete()
46 '''
47 #              查詢        條件            所有
48 data =Session.query(User_2).filter_by(id=2).all()
49 #                                 多個條件
50 data2 =Session.query(User_2).filter(User_2.id>2).filter(User_2.id<5).all()
51 
52 
53 #改
54 
55 Session.query(User_2).filter(User_2.id ==2).update({"name" : "099"})
56 print(data)
57 print(data2)
58 '''
59 print(Session.query(User).filter(User.id>2).filter(User.name.in_(["sa",'sa2'])).all())
60 Session.rollback()#回滾操作
61 print(Session.query(User).filter(User.id>2).filter(User.name.in_(["sa",'sa2'])).all())
62 '''
63 print(Session.query(User_2).filter(User_2.id>2).filter(User_2.name.in_(["sa",'sa2'])).count())#統計符合條件出現的次數
64 counts=Session.query(User_2).filter(User_2.id>2).filter(User_2.name.in_(['bcd'])).count()#統計符合條件出現的次數
65 print(counts)
66 #分組查詢              欄位        統計次數                  欄位
67 gurps=Session.query(User_2.name,func.count(User_2.name)).group_by(User_2.name).all()
68 print(gurps)
69 #                                                              以addrs為條件
70 gurps1=Session.query(User_2.name,func.count(User_2.name)).group_by(User_2.addr).all()
71 print(gurps1)
72 
73 
74 Session.commit()#關閉事務
View Code

sqlalchemy 基本操作

 1 from sqlalchemy.ext.declarative import declarative_base
 2 from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index
 3 from sqlalchemy.orm import sessionmaker, relationship
 4 from sqlalchemy import create_engine
 5 #                                         用戶 密碼  主機             庫
 6 engine = create_engine("mysql+pymysql://root:[email protected]:3306/test",encoding="utf-8",echo=True)
 7 
 8 Base = declarative_base()#生成orm 基類
 9 class User(Base):
10     __tablename__='info_l' #表名
11     id = Column(Integer,primary_key=True)#整數類型  設為主鍵
12     name = Column(String(32))#字元串類型
13     addrs= Column(String(256))
14 
15 Base.metadata.create_all(engine)#創建表結構
16 
17 Session_class=sessionmaker(bind=engine)#創建與資料庫的會話 類
18 Session=Session_class()#生成實例
19 
20 user_obj =User(name="sa",addrs="1234")#生成你要創建的數據對象
21 print(user_obj.name,user_obj.addrs)#此時並未創建對象
22 Session.add(user_obj)#開啟事務進行連接 添加記錄
23 Session.commit()#關閉事務
View Code

 

外鍵操作示例

 1 #!usr/bin/env python
 2 #-*-coding:utf-8-*-
 3 # Author calmyan 
 4 #python 
 5 #2017/7/7    10:28
 6 #__author__='Administrator'
 7 import sqlalchemy
 8 from sqlalchemy.ext.declarative import declarative_base
 9 from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index,DATE
10 from sqlalchemy.orm import sessionmaker, relationship
11 from sqlalchemy import create_engine
12 #                                         用戶 密碼  主機             庫
13 engine = create_engine("mysql+pymysql://root:[email protected]:3306/test",encoding="utf-8",echo=False)
14 
15 Base = declarative_base()#生成orm 基類
16 
17 class Studes(Base):#學生類
18     __tablename__ ='studes'
19     id = Column(Integer,primary_key=True)#整數類型  設為主鍵
20     name = Column(String(32),nullable=False)#字元串類型 不能為空
21     register_day= Column(DATE,nullable=False)#日期
22 
23     def __repr__(self):#輸出查詢
24         return '%s>name:%s--register_day :%s'%(self.id,self.name,self.register_day)
25 
26 
27 class Studes_Cr(Base):#課程類
28     __tablename__ ='stud_cr'
29     id = Column(Integer,primary_key=True)#整數類型  設為主鍵
30     day= Column(Integer,nullable=False)
31     status= Column(String(35),nullable=False)#上課記錄
32     stu_id= Column(Integer,ForeignKey("studes.id",))#外鍵關聯
33     studes=relationship("Studes",backref="m_study_reg")#自定義關聯反查
34 
35     def __repr__(self):#輸出查詢         自定義 外鍵關聯調用
36         return '%s>day:%s  status:%s'%(self.studes.name,self.day,self.status)
37 
38 Base.metadata.create_all(engine)#創建表結構
39 
40 Session_class=sessionmaker(bind=engine)#創建與資料庫的會話 類
41 Session=Session_class()#生成實例
42 
43 '''
44 s1 = Studes(name="Alex",register_day='2017-05-06')#學生
45 s2 = Studes(name="bolg",register_day='2017-03-06')
46 s3 = Studes(name="calm",register_day='2017-01-07')
47 s4 = Studes(name="Defr",register_day='2017-03-16')
48 s5 = Studes(name="Eale",register_day='2017-02-24')
49 
50 study_obj1=Studes_Cr(day=1,status="YES",stu_id=1)#上課記錄
51 study_obj2=Studes_Cr(day=1,status="YES",stu_id=2)#上課記錄
52 study_obj3=Studes_Cr(day=1,status="NO",stu_id=3)#上課記錄
53 study_obj4=Studes_Cr(day=1,status="YES",stu_id=4)#上課記錄
54 study_obj5=Studes_Cr(day=2,status="NO",stu_id=1)#上課記錄
55 study_obj6=Studes_Cr(day=2,status="YES",stu_id=2)#上課記錄
56 study_obj7=Studes_Cr(day=2,status="YES",stu_id=3)#上課記錄
57 
58 #一次全部添加
59 Session.add_all([s1,s2,s3,s4,s5,study_obj1,study_obj2,study_obj3,study_obj4,study_obj5,study_obj6,study_obj7])
60 '''
61 
62 
63 #查詢 學生對應的信息
64 stu_obj= Session.query(Studes).filter(Studes.name=="Alex").first()
65 print(stu_obj)
66 #通過外鍵進行相關信息查詢
67 print(stu_obj.m_study_reg)
68 
69 Session.commit()
View Code

 

外鍵 多外鍵關聯示例:   多外鍵關聯.py  多外鍵_操作.py

 多外鍵關聯.py

 1 #!usr/bin/env python
 2 #-*-coding:utf-8-*-
 3 # Author calmyan 
 4 #python 
 5 #2017/7/7    13:06
 6 #__author__='Administrator'
 7 
 8 from sqlalchemy import Integer, ForeignKey, String, Column
 9 from sqlalchemy.ext.declarative import declarative_base
10 from sqlalchemy.orm import relationship
11 from sqlalchemy import create_engine
12 
13 Base = declarative_base()#生成orm 基類
14 class Customer(Base):
15     __tablename__ = 'customer'
16     id = Column(Integer, primary_key=True)
17     name = Column(String(32),nullable=False)
18 
19     billing_address_id = Column(Integer, ForeignKey("address.id"))#帳單地址外鍵關聯
20     shipping_address_id = Column(Integer, ForeignKey("address.id"))#收貨地址外鍵關聯
21 
22     billing_address = relationship("Address",foreign_keys=[billing_address_id])#帳單地址自定義反查 對應外鍵
23     shipping_address = relationship("Address",foreign_keys=[shipping_address_id])#收貨地址
24 
25 class Address(Base):
26     __tablename__ = 'address'
27     id = Column(Integer, primary_key=True)
28     street = Column(String(32))#詳細
29     city = Column(String(32))#市
30     state = Column(String(255))#省
31 
32     def __repr__(self):
33         return self.state+self.city+self.street
34 
35 #                                         用戶 密碼  主機             庫
36 engine = create_engine("mysql+pymysql://root:[email protected]:3306/test",encoding="utf-8",echo=False)
37 
38 
39 Base.metadata.create_all(engine)#創建表結構
View Code

多外鍵_操作.py

 

 1 #!usr/bin/env python
 2 #-*-coding:utf-8-*-
 3 # Author calmyan 
 4 #python 
 5 #2017/7/7    13:21
 6 #__author__='Administrator'
 7 import os ,sys
 8 from day66 import 多外鍵關聯
 9 from sqlalchemy.orm import relationship,sessionmaker
10 from sqlalchemy import create_engine
11 Session_class=sessionmaker(bind=多外鍵關聯.engine)#創建與資料庫的會話 類
12 Session=Session_class()#生成實例
13 '''
14 addr1=多外鍵關聯.Address(street="btxw",city='xy',state="fj")
15 addr2=多外鍵關聯.Address(street="jjqy",city='qz',state="fj")
16 addr3=多外鍵關聯.Address(street="ml",city='pt',state="fj")
17 
18 Session.add_all([addr1,addr2,addr3])#寫入資料庫
19 
20 c1=多外鍵關聯.Customer(name='calmyan',billing_address=addr1,shipping_address=addr1)
21 c2=多外鍵關聯.Customer(name='alex',billing_address=addr3,shipping_address=addr2)
22 Session.add_all([c1,c2])
23 '''
24 
25 #查詢
26 sobj=Session.query(多外鍵關聯.Customer).filter(多外鍵關聯.Customer.name=='calmyan').first()
27 
28 print(sobj.name,sobj.billing_address,sobj.shipping_address)
29 
30 Session.commit()
View Code

 

多對多外鍵示例:

orm_s.py

 1 #!usr/bin/env python
 2 #-*-coding:utf-8-*-
 3 # Author calmyan 
 4 #python 
 5 #2017/7/7    14:07
 6 #__author__='Administrator'
 7 
 8 #一本書可以有多個作者，一個作者又可以出版多本書
 9 
10 
11 from sqlalchemy import Table, Column, Integer,String,DATE, ForeignKey
12 from sqlalchemy.orm import relationship
13 from sqlalchemy.ext.declarative import declarative_base
14 from sqlalchemy import create_engine
15 from sqlalchemy.orm import sessionmaker
16 
17 Base = declarative_base()
18 
19 #創建第三張表,自動維護
20 book_m2m_author = Table('book_m2m_author', Base.metadata,
21                         Column('book_id',Integer,ForeignKey('books.id')),#關聯外鍵,書id
22                         Column('author_id',Integer,ForeignKey('authors.id')),#關聯外鍵,作者id
23                         )
24 
25 class Book(Base):#書名
26     __tablename__ = 'books'
27     id = Column(Integer,primary_key=True)
28     name = Column(String(64))
29     pub_date = Column(DATE)
30     authors = relationship('Author',secondary=book_m2m_author,backref='books')
31 
32     def __repr__(self):
33         return self.name
34 
35 class Author(Base):#作者
36     __tablename__ = 'authors'
37     id = Column(Integer, primary_key=True)
38     name = Column(String(32))
39 
40     def __repr__(self):
41         return self.name
42 
43 #                                         用戶 密碼  主機             庫
44 engine = create_engine("mysql+pymysql://root:[email protected]:3306/test?charset=utf8",encoding="utf-8",echo=False)
45 
46 
47 Base.metadata.create_all(engine)#創建表結構
View Code

orm_s_aut.py

 1 #!usr/bin/env python
 2 #-*-coding:utf-8-*-
 3 # Author calmyan 
 4 #python 
 5 #2017/7/7    14:38
 6 #__author__='Administrator'
 7 
 8 from  day66 import orm_s
 9 from sqlalchemy.orm import relationship,sessionmaker
10 Session_class = sessionmaker(bind=orm_s.engine) #創建與資料庫的會話session class ,註意,這裡返回給session的是個class,不是實例
11 s = Session_class() #生成session實例
12 '''
13 #book名
14 b1 = orm_s.Book(name="跟Alex學Python")
15 b2 = orm_s.Book(name="跟Alex學把妹")
16 b3 = orm_s.Book(name="跟Alex學裝逼")
17 b4 = orm_s.Book(name="跟Alex學開車")
18 
19 #作者名
20 a1 = orm_s.Author(name="Alex")
21 a2 = orm_s.Author(name="Jack")
22 a3 = orm_s.Author(name="Rain")
23 
24 #關聯關係
25 b1.authors = [a1,a2]
26 b2.authors = [a1,a2,a3]
27 
28 s.add_all([b1,b2,b3,b4,a1,a2,a3])
29 '''
30 
31 
32 '''
33 #查詢  作者表                   條件       作者名==alex
34 aut_obj=s.query(orm_s.Author).filter(orm_s.Author.name=='Alex').first()#返回一個對象
35 print(aut_obj,aut_obj.books,aut_obj.books[0])
36 '''
37 
38 #更新
39 s.query(orm_s.Book).filter(orm_s.Book.id ==2).update({"pub_date" : "2017-06-07"})
40 
41 #查詢  書表                   條件       書id==2
42 book_obj=s.query(orm_s.Book).filter(orm_s.Book.id==2).first()
43 book_obj2=s.query(orm_s.Book).filter(orm_s.Book.id==1).first()
44 print(book_obj.authors,book_obj)#輸出書的作者  書名
45 #book_obj.authors.remove(aut_obj)#刪除書中的一個作者
46 print(book_obj2.authors,book_obj2)#輸出書的作者  書名
47 
48 #刪除作者,會把這個作者跟所有書的關聯關係數據也自動刪除
49 '''
50 s.delete(aut_obj)
51 '''
52 book_obj=s.query(orm_s.Book).filter(orm_s.Book.id==2).first()
53 book_obj2=s.query(orm_s.Book).filter(orm_s.Book.id==1).first()
54 print(book_obj.authors,book_obj)#輸出書的作者  書名
55 print(book_obj2.authors,book_obj2)#輸出書的作者  書名
56 
57 
58 s.commit()
View Code

 

 

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • json&pickle序列化
    一、用途 我們需要將記憶體中的數據進行序列化，即寫入文件中時，寫入的類型只能是字元串或者二進位類型。但是如果我們想要將複雜一些的數據類型，如：列表、字典或者函數之類的同樣進行序列化，我們就要用到 json或者pickle。 二、json序列化 1、dumps序列化和loads反序列化 dumps把數據 ...
  • python練習題1-10
    3、一個整數，它加上100後是一個完全平方數，再加上168又是一個完全平方數，請問該數是多少？ 方法一： 方法二：看了別人的思路，我覺得我儼然是個弱智。 4、輸入某年某月某日，判斷這一天是這一年的第幾天？ 方法一： 方法二： 5、輸入三個整數x,y,z，請把這三個數由小到大輸出。 方法一 方法二： ...
  • Python3 basedao.py的優化
    之前一篇Python 封裝DBUtils 和pymysql 中寫過一個basedao.py，最近幾天又重新整理了下思緒，優化了下 basedao.py，目前支持的方法還不多，後續會進行改進、添加。 主要功能： 1.查詢單個對象： 所需參數：表名，過濾條件 2.查詢多個對象： 所需參數：表名，過濾條件 ...
  • php的serialize()函數和unserialize()函數
    適用情境：serialize()返回字元串，此字元串包含了表示value的位元組流，可以存儲於任何地方。這有利於存儲或傳遞 PHP 的值，同時不丟失其類型和結構。比較有用的地方就是將數據存入資料庫或記錄在文件中的時候 serialize()可處理處資源類型外所有的類型，也可以序列化對象 <?php $ ...
  • JDBC03 利用JDBC實現事務提交與回滾【調用Connection中的方法實現事務管理】
    目錄 1 Connection中的重用方法 2 JDBC事務管理經典案例 1 Connection類中常用的方法回顧 1.1 Statement createStatement() throws SQLException; 創建一個Statement實例（即：創建一個SQL執行對象） 1.2 Pre ...
  • Dubbo快速入門
    Dubbo是一個分散式服務框架，既然是服務，必然存在服務提供者與服務調用者。 接下來，我們先編寫一個服務提供者。工程仍然使用上篇文章spring4入門中的工程。 我們在pom.xml中加入dubbo的依賴 <dependency> <groupId>com.alibaba</groupId> <ar ...
  • 數組指針和指針數組的區別
    數組指針（也稱行指針）定義 int (*p)[n];()優先順序高，首先說明p是一個指針，指向一個整型的一維數組，這個一維數組的長度是n，也可以說是p的步長。也就是說執行p+1時，p要跨過n個整型數據的長度。 如要將二維數組賦給一指針，應這樣賦值：int a[3][4];int (*p)[4]; // ...
  • Hibernate使用註解進行ORM映射實例
    在上一篇博客中，我們通過xml配置文件進行實體類和表的映射，但是近兩年來有更多的項目對一些比較穩定的實體類使用了註解進行ORM映射，這樣使得編程更加簡潔、簡單。其實使用註解進行ORM映射和使用xml進行映射沒有太多的操作流程上的變化，主要步驟為：導包、編寫帶註解的實體類、編寫核心配置文件、編寫測試類 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類