python學(xué)習(xí)之pymysql和sqlalchemy

PyMySQL 是在 Python3.x 版本中用于連接 MySQL 服務(wù)器的一個庫,
Python2中則使用MySQLdb。
python學(xué)習(xí)之pymysql和sqlalchemy
python學(xué)習(xí)之pymysql和sqlalchemy
數(shù)據(jù)庫查詢操作
python學(xué)習(xí)之pymysql和sqlalchemy

創(chuàng)新互聯(lián)建站成立十年來，這條路我們正越走越好，積累了技術(shù)與客戶資源，形成了良好的口碑。為客戶提供成都做網(wǎng)站、網(wǎng)站建設(shè)、外貿(mào)營銷網(wǎng)站建設(shè)、網(wǎng)站策劃、網(wǎng)頁設(shè)計、主機(jī)域名、網(wǎng)絡(luò)營銷、VI設(shè)計、網(wǎng)站改版、漏洞修補(bǔ)等服務(wù)。網(wǎng)站是否美觀、功能強(qiáng)大、用戶體驗好、性價比高、打開快等等，這些對于網(wǎng)站建設(shè)都非常重要，創(chuàng)新互聯(lián)建站通過對建站技術(shù)性的掌握、對創(chuàng)意設(shè)計的研究為客戶提供一站式互聯(lián)網(wǎng)解決方案，攜手廣大客戶，共同發(fā)展進(jìn)步。

01_python數(shù)據(jù)庫編程基本操作.py

import pymysql

#1). 創(chuàng)建數(shù)據(jù)庫連接, autocommit是否自動提交修改到數(shù)據(jù)庫中.
conn = pymysql.connect(host='localhost', user='root', password='westos',
                db='Blog', port=3306, autocommit=True, charset='utf8')
#2). 創(chuàng)建游標(biāo)(用來執(zhí)行sql語句的)
cur = conn.cursor()

#3). 執(zhí)行sql語句
insert_sql = 'insert into users(username) values ("user6");'
cur.execute(insert_sql)

print("插入數(shù)據(jù)成功.......")
#4). 關(guān)閉游標(biāo)
cur.close()
#5）.關(guān)閉連接
conn.close()

02_python數(shù)據(jù)庫編程基本操作.py

class Connection(object):
  def __enter__(self):
        Context manager that returns a Cursor
        warnings.warn(
            "Context manager API of Connection object is deprecated; Use conn.begin()",
            DeprecationWarning)
        return self.cursor()

    def __exit__(self, exc, value, traceback):
        On successful exit, commit. On exception, rollback(回滾)
        if exc:
            self.rollback()
        else:
            self.commit()
import pymysql

#使用with語句是， pymysql.connect返回的是數(shù)據(jù)庫游標(biāo)。(具體的內(nèi)容查看源代碼)
with pymysql.connect(host='localhost', user='root', password='westos',
                db='Blog', port=3306, autocommit=True, charset='utf8') as cur:
    #3). 執(zhí)行sql語句(增刪改)
    insert_sql = 'insert into users(username) values ("user7");'
    cur.execute(insert_sql)
    print("插入數(shù)據(jù)成功.......")

03_數(shù)據(jù)庫批量操作.py

import pymysql

users = [('redhat' + str(i), 'passwd'+str(i)) for i in range(100)]
#users = [('redhat1', 'passwd1'), ('redhat2', 'passwd2'), .......]

#使用with語句是， pymysql.connect返回的是數(shù)據(jù)庫游標(biāo)。(具體的內(nèi)容查看源代碼)
with pymysql.connect(host='localhost', user='root', password='westos',
                db='Blog', port=3306, autocommit=True, charset='utf8') as cur:
    #3). 執(zhí)行sql語句(增刪改)
    insert_sql = 'insert into users(username, password) values (%s, %s);'
    #execute: 執(zhí)行一條sql語句。
    #executemany: 執(zhí)行多條sql語句。
    #'insert into users(username, password) values (%s, %s);' %users[0]
    #'insert into users(username, password) values (%s, %s);' %('redhat1', 'passwd1')
    #'insert into users(username, password) values (%s, %s);' %users[1]
    #'insert into users(username, password) values (%s, %s);' %users[2]
    cur.executemany(insert_sql, users)
    print("插入數(shù)據(jù)成功.......")

04_python查詢數(shù)據(jù)庫信息.py

import pymysql

with pymysql.connect(host='localhost', user='root', password='westos',
                db='Blog', port=3306, autocommit=True, charset='utf8') as cur:
    #3). 執(zhí)行sql語句(增刪改)
    query_sql = 'select * from users where username like "user%";'
    #Number of affected rows
    result = cur.execute(query_sql)
    print("符合條件的記錄數(shù): ", result)

    #print(cur.fetchone())
    #print(cur.fetchmany(2))
    users_info = cur.fetchall()

#以表格方式美觀的打印。
from  prettytable import  PrettyTable
pt = PrettyTable(field_names=['編號', '用戶名', '密碼'])
for user in users_info:
    pt.add_row(user)
print(pt)

05_sqlite數(shù)據(jù)庫.py

1. 什么是sqlite數(shù)據(jù)庫?
SQLite是內(nèi)嵌在Python中的輕量級、基于磁盤文件袋額數(shù)據(jù)庫管理系統(tǒng)(就是一個文件)，
不需要安裝和配置服務(wù)，支持使用SQL語句來訪問數(shù)據(jù)庫。該數(shù)據(jù)庫使用C語言開發(fā)，支持大多數(shù)SQL91標(biāo)準(zhǔn)，
支持原子的、一致的、獨立的和持久的事務(wù)，不支持外鍵限制；通過數(shù)據(jù)庫級的獨占性和共享性鎖定來實現(xiàn)獨立事務(wù)，
當(dāng)多個線程同時訪問同一個數(shù)據(jù)庫并試圖寫入數(shù)據(jù)時，每一時刻只有一個線程可以寫入數(shù)據(jù)。
2. sqlite數(shù)據(jù)庫的特性:
　　SQLite支持最大140TB大小的單個數(shù)據(jù)庫，每個數(shù)據(jù)庫完全存儲在單個磁盤文件中，
以B+樹數(shù)據(jù)結(jié)構(gòu)的形式存儲，一個數(shù)據(jù)庫就是一個文件，通過直接復(fù)制數(shù)據(jù)庫文件就可以實現(xiàn)數(shù)據(jù)庫的備份。
如果需要使用可視化管理工具，可以下載并使用SQLiteManager、SQLite Database Browser 或其他類似工具。
import sqlite3
#1). 創(chuàng)建連接
conn = sqlite3.connect(database='users.sqlite')

#2). 創(chuàng)建游標(biāo)
cur = conn.cursor()

#3). 操作
#if not exists如果數(shù)據(jù)庫標(biāo)不存在時創(chuàng)建表，否則不做操作。
create_sql = 'create table if not exists userinfo1 (id int auto_increment primary key , name varchar(10) unique, passwd varchar(10) default "123");'
cur.execute(create_sql)
insert_sql = 'insert into userinfo1(name) values("user2");'
cur.execute(insert_sql)
#數(shù)據(jù)操作(增刪改)一定需要提交。
conn.commit()
select_sql = 'select * from userinfo1'
cur.execute(select_sql)
print("查詢結(jié)果: ", cur.fetchall())

cur.close()
conn.close()

什么是ORM?
ORM,即Object-Relational Mapping(對象關(guān)系映射),它的作用是在關(guān)系型數(shù)據(jù)庫和
業(yè)務(wù)實體對象之間作一個映射,這樣,我們在具體的操作業(yè)務(wù)對象的時候,就不需要再
去和復(fù)雜的SQL語句打交道,只需簡單的操作對象的屬性和方法。
python學(xué)習(xí)之pymysql和sqlalchemy
安裝sqlalchemy

  1. 需要一臺有安裝mysql數(shù)據(jù)庫的機(jī)器
  2. 安裝模塊: pip3 install sqlalchemy
  3. 查看版本信息python學(xué)習(xí)之pymysql和sqlalchemy
    連接數(shù)據(jù)庫
    在sqlalchemy中,session用于創(chuàng)建程序與數(shù)據(jù)庫之間的會話。所有對象的載
    入和保存都需要通過session對象。
    python學(xué)習(xí)之pymysql和sqlalchemy
    創(chuàng)建映射(創(chuàng)建表)
    一個映射對應(yīng)著一個Python類,用來表示一個表的結(jié)構(gòu)。
    python學(xué)習(xí)之pymysql和sqlalchemy
    添加單條數(shù)據(jù)
    python學(xué)習(xí)之pymysql和sqlalchemy
    添加多條數(shù)據(jù)
    python學(xué)習(xí)之pymysql和sqlalchemy
    查找數(shù)據(jù)
    在sqlalchemy模塊中,查找數(shù)據(jù)給提供了query()的方法
    python學(xué)習(xí)之pymysql和sqlalchemy
    刪除數(shù)據(jù)
    python學(xué)習(xí)之pymysql和sqlalchemy

06_對象關(guān)系映射.py

import sqlalchemy
from sqlalchemy import Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
import pymysql
pymysql.install_as_MySQLdb()

#object(oop) ---> mysql(SQL)
#1). 創(chuàng)建數(shù)據(jù)庫引擎(連接數(shù)據(jù)庫的過程)
#echo=True顯示翻譯好的SQL語句。
from sqlalchemy.orm import Session, sessionmaker

engine = sqlalchemy.create_engine("mysql://root:westos@localhost/Blog",
                         encoding='utf8', echo=True)

#2). 建立緩存
session = sessionmaker(bind=engine)()

#3). 創(chuàng)建數(shù)據(jù)庫對象需要繼承的基類
Base = declarative_base()

#4). 創(chuàng)建類, 一個類就是一個數(shù)據(jù)庫表
class Student(Base):
    # 數(shù)據(jù)庫表的名稱
    __tablename__ = 'student_info'
    #數(shù)據(jù)庫表的屬性信息
    id = Column(Integer, primary_key=True, autoincrement=True)
    name = Column(String(20))
    sex = Column(String(10))

    #def __repr__(self):
    #return  'Student<%s>' %(self.name)

if __name__ == '__main__':
    # 根據(jù)設(shè)置的信息創(chuàng)建數(shù)據(jù)庫表-(創(chuàng)建類:創(chuàng)建數(shù)據(jù)庫表的過程)
    Base.metadata.create_all(engine)

    #添加數(shù)據(jù)信息(實例化對象: 添加一條數(shù)據(jù)/記錄)
    #INSERT INTO student_info (id, name, sex) VALUES (%(id)s, %(name)s, %(sex)s)
    stu1 = Student(id=2, name='westos2', sex='男')
    #stu2 = Student(id=3, name='westos3', sex='男')
    #stu3 = Student(id=4, name='westos4', sex='女')
    session.add_all([stu1, ])
    session.commit()

    #查詢數(shù)據(jù)信息
    print(session.query(Student).all())

    #根據(jù)篩選條件查詢信息
    print(session.query(Student).filter_by(name='westos1').all())
    print(session.query(Student).filter_by(name='westos1').first())
    print(session.query(Student).filter_by(name='westoshdhwhdewd').first())

    #刪除數(shù)據(jù)
    stu1 = session.query(Student).filter_by(name='westos2').first()

    print("before delete: ", stu1)
    session.delete(stu1)
    session.commit()
    stu1 = session.query(Student).filter_by(name='westos1').first()
    print("after delete: ", stu1)

當(dāng)前文章：python學(xué)習(xí)之pymysql和sqlalchemy
URL標(biāo)題：http://www.muchs.cn/article12/jpcsdc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供動態(tài)網(wǎng)站、網(wǎng)站改版、全網(wǎng)營銷推廣、App開發(fā)、商城網(wǎng)站、品牌網(wǎng)站設(shè)計

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

網(wǎng)站建設(shè)網(wǎng)站維護(hù)公司