2. 程式人生 > >python3入門教程（二）操作數據庫一

python3入門教程（二）操作數據庫一

阿新 • • 發佈：2018-11-15
pri 只需要 圖片 pytho 對象 ima cdc 一行 結果

概述

　　最近在準備寫一個爬蟲的練手項目，基本想法是把某新聞網站的內容分類爬取下來，保存至數據庫，再通過接口對外輸出（提供後臺查詢接口）。那麽問題就來了，python到底是怎麽去操作數據庫的呢？我們今天就來研究下。

準備

我這邊數據庫使用的是mysql5.7，python去操作mysql數據庫需要使用到pymysql模塊。

安裝pymysql很簡單，可以使用pip，

pip install pymysql

也可以通過pycharm直接添加安裝。

使用操作

我們新建一個數據庫，名字就叫做news，我們再創建一張news表（取名字這種事情真的非常糾結），語句如下：

CREATE TABLE `news` (
  `id` bigint(100) NOT NULL AUTO_INCREMENT,
  `title` varchar(1000) DEFAULT NULL,
  `url` varchar(1000) DEFAULT NULL,
  `hash` varchar(1000) DEFAULT NULL,
  `publish_time` varchar(15) DEFAULT NULL,
  `catagary` varchar(1) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8

這張表設計的有些隨意，不過這不是重點，重點是我們如何利用python去操作這張表，下面我們就進入主題。

首先，我們新建python file，然後導入我們要用到的模塊

import pymysql

1.獲取數據庫連接及遊標

之前有用過數據庫的同學肯定知道，用代碼去操作數據庫之前，肯定先要獲取連接，後續的增刪改查都是基於這個連接，當然，相應的操作完成之後，一定要記得把連接關閉，不然會造成一些不好的後果。

python獲取數據庫連接代碼如下：

import pymysql

# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn)

運行之後輸出：

E:\pythonsource\venv\Scripts\python.exe E:/pythonsource/study/pymysqldemo.py
<pymysql.connections.Connection object at 0x000001D359180B00>

Process finished with exit code 0

顯然，我們已經成功獲取到了一個連接，當然要執行sql語句，我們好需要獲取一個遊標對象，

import pymysql
# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn) 
# 獲取操作sql的遊標對象（這樣寫默認返回的數據類型是元組，我們下面會有介紹）
cursor = conn.cursor()

print(cursor)

運行之後輸出：

E:\pythonsource\venv\Scripts\python.exe E:/pythonsource/study/pymysqldemo.py
<pymysql.connections.Connection object at 0x0000025F14470B70>
<pymysql.cursors.Cursor object at 0x0000025F14AC8E10>

Process finished with exit code 0

遊標對象已經成功拿到了

2.新增數據

import pymysql

# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn)
# 獲取操作sql的遊標對象
cursor = conn.cursor()
print(cursor)
# 新增一條數據
insert_sql = ‘insert into news(title, url, hash, publish_time, catagary) values(%s, %s, %s, %s, %s)‘
row = cursor.execute(insert_sql, (‘百度‘, ‘http://www.baidu.com‘, ‘1qaz2wsx‘, ‘2018-11-02‘, ‘0‘)) # 參數為元組類型
print(row)
print(cursor.lastrowid) # 獲取最後一次自增的ID

執行上面的代碼，輸出結果如下：

E:\pythonsource\venv\Scripts\python.exe E:/pythonsource/study/pymysqldemo.py
<pymysql.connections.Connection object at 0x0000023455416358>
<pymysql.cursors.Cursor object at 0x00000234559F8E10>
1
2

Process finished with exit code 0

從輸出結果可以看出，似乎已經插入成功了，我們取數據庫看一下，結果是令人失望的，數據庫沒有，什麽情況呢？

原因其實很簡單，我們沒有做commit操作，我們把commit加上，再試下

import pymysql

# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn)
# 獲取操作sql的遊標對象
cursor = conn.cursor()
print(cursor)

# 新增一條數據
insert_sql = ‘insert into news(title, url, hash, publish_time, catagary) values(%s, %s, %s, %s, %s)‘  # 使用pymysql的參數化語句防止SQL註入
# 返回受影響的行數
row = cursor.execute(insert_sql, (‘百度‘, ‘http://www.baidu.com‘, ‘1qaz2wsx‘, ‘2018-11-02‘, ‘0‘))  # 參數為元組類型
print(row)
print(cursor.lastrowid)  # 獲取最後一次自增的ID

conn.commit()  # 提交數據
cursor.close()  # 關閉遊標
conn.close()  # 關閉連接

下面我們再運行下，輸出如下：

E:\pythonsource\venv\Scripts\python.exe E:/pythonsource/study/pymysqldemo.py
<pymysql.connections.Connection object at 0x000001D60F605630>
<pymysql.cursors.Cursor object at 0x000001D60FD88E80>
1
3

Process finished with exit code 0　

我們查一下數據庫，這下就有了，插入成功了。

技術分享圖片

當然也可以批量插入，使用executemany

import pymysql

# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn)
# 獲取操作sql的遊標對象
cursor = conn.cursor()
print(cursor)

# 新增一條數據
insert_sql = ‘insert into news(title, url, hash, publish_time, catagary) values(%s, %s, %s, %s, %s)‘  # 使用pymysql的參數化語句防止SQL註入
# 返回受影響的行數
#row = cursor.execute(insert_sql, (‘百度‘, ‘http://www.baidu.com‘, ‘1qaz2wsx‘, ‘2018-11-02‘, ‘0‘))  # 參數為元組類型
#print(row)
#print(cursor.lastrowid)  # 獲取最後一次自增的ID

# 新增多條數據
row = cursor.executemany(insert_sql, [(‘百度1‘, ‘http://www.baidu.com‘, ‘1qaz2wsx‘, ‘2018-11-02‘, ‘0‘),
                                      (‘百度2‘, ‘http://www.baidu.com‘, ‘1qaz2wsx‘, ‘2018-11-02‘, ‘0‘),
                                      (‘百度3‘, ‘http://www.baidu.com‘, ‘1qaz2wsx‘, ‘2018-11-02‘, ‘0‘)])

print(row)

conn.commit()  # 提交數據
cursor.close()  # 關閉遊標
conn.close()  # 關閉連接

執行上面的腳本，輸出結果如下：

E:\pythonsource\venv\Scripts\python.exe E:/pythonsource/study/pymysqldemo.py
<pymysql.connections.Connection object at 0x000001A454EF5630>
<pymysql.cursors.Cursor object at 0x000001A455678E48>
3
Process finished with exit code 0

查詢數據庫，如下：

技術分享圖片

批量插入成功。

3.查詢數據

前面插入數據成功了，我們研究下怎麽查詢

import pymysql

# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn)
# 獲取操作sql的遊標對象
cursor = conn.cursor()
print(cursor)

query_sql = ‘select * from news where id = %s‘
row = cursor.execute(query_sql, (3,))
print(row)  # 查詢到的行數
print(cursor.fetchall())  # fetchall:獲取所有行的信息 fetchone:獲取結果集中第一行的數據 fetchmany:獲取結果集中的多行


conn.commit()  # 提交數據
cursor.close()  # 關閉遊標
conn.close()  # 關閉連接

執行上面的查詢，輸出：

E:\pythonsource\venv\Scripts\python.exe E:/pythonsource/study/pymysqldemo.py
<pymysql.connections.Connection object at 0x000001C5D9107320>
<pymysql.cursors.Cursor object at 0x000001C5D9748EF0>
1
((3, ‘百度‘, ‘http://www.baidu.com‘, ‘1qaz2wsx‘, ‘2018-11-02‘, ‘0‘),)

Process finished with exit code 0

從輸出結果我們可以看到，最後拿到的結果集是一個元組類型，那假如我們想要的是字典類型呢？

我們只需要在初始化遊標的時候，稍微設置一下 

cursor = conn.cursor(pymysql.cursors.DictCursor)

我們加上再試下，

import pymysql

# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn)
# 獲取操作sql的遊標對象
cursor = conn.cursor(pymysql.cursors.DictCursor)
print(cursor)

query_sql = ‘select * from news where id = %s‘
row = cursor.execute(query_sql, (3,))
print(row)  # 查詢到的行數
print(cursor.fetchall())  # fetchall:獲取所有行的信息 fetchone:獲取結果集中第一行的數據 fetchmany:獲取結果集中的多行


conn.commit()  # 提交數據
cursor.close()  # 關閉遊標
conn.close()  # 關閉連接

運行之後輸出：

E:\pythonsource\venv\Scripts\python.exe E:/pythonsource/study/pymysqldemo.py
<pymysql.connections.Connection object at 0x000002A433136358>
<pymysql.cursors.DictCursor object at 0x000002A433778E48>
1
[{‘id‘: 3, ‘title‘: ‘百度‘, ‘url‘: ‘http://www.baidu.com‘, ‘hash‘: ‘1qaz2wsx‘, ‘publish_time‘: ‘2018-11-02‘, ‘catagary‘: ‘0‘}]

Process finished with exit code 0

可以看到，結果集的數據類型變了，這樣比較方面去處理具體的數據內容。

4.更新數據

import pymysql

# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn)
# 獲取操作sql的遊標對象
cursor = conn.cursor(pymysql.cursors.DictCursor)
print(cursor)

update_sql = ‘update news set title = %s where id = %s‘
row_upd = cursor.execute(update_sql, (‘百度Updata‘, 3)) # 也可使用executemany實現批量更新
print(row_upd)

query_sql = ‘select * from news where id = %s‘
row = cursor.execute(query_sql, (3,))
print(row)  # 查詢到的行數
print(cursor.fetchall())  # fetchall:獲取所有行的信息 fetchone:獲取結果集中第一行的數據 fetchmany:獲取結果集中的多行


conn.commit()  # 提交數據
cursor.close()  # 關閉遊標
conn.close()  # 關閉連接

我們更新id=3的那條數據的標題，運行上面的代碼，輸出：

E:\pythonsource\venv\Scripts\python.exe E:/pythonsource/study/pymysqldemo.py
<pymysql.connections.Connection object at 0x000001FCDBB36390>
<pymysql.cursors.DictCursor object at 0x000001FCDC158EB8>
1
1
[{‘id‘: 3, ‘title‘: ‘百度Updata‘, ‘url‘: ‘http://www.baidu.com‘, ‘hash‘: ‘1qaz2wsx‘, ‘publish_time‘: ‘2018-11-02‘, ‘catagary‘: ‘0‘}]

Process finished with exit code 0

更新成功。

5.刪除數據

刪除數據其實更上面的更新差不多，只是sql不一樣。

import pymysql

# 獲取連接 參數（數據庫IP,端口，用戶名,密碼,數據庫名稱，編碼格式）
conn = pymysql.connect(host=‘127.0.0.1‘, port=3306,user=‘root‘, passwd=‘123456‘, db=‘news‘, charset=‘utf8‘)
print(conn)
# 獲取操作sql的遊標對象
cursor = conn.cursor(pymysql.cursors.DictCursor)
print(cursor)

delete_sql = ‘delete from news where id=%s‘
row_delete = cursor.execute(delete_sql, (3,)) # 也可以使用executemany實現批量刪除

query_sql = ‘select * from news where id = %s‘
row = cursor.execute(query_sql, (3,))
print(row)  # 查詢到的行數
print(cursor.fetchall())  # fetchall:獲取所有行的信息 fetchone:獲取結果集中第一行的數據 fetchmany:獲取結果集中的多行


conn.commit()  # 提交數據
cursor.close()  # 關閉遊標
conn.close()  # 關閉連接

python3入門教程（二）操作數據庫一

相關推薦

python3入門教程（二）操作數據庫一

pri 只需要 圖片 pytho 對象 ima cdc 一行 結果 概述 　　最近在準備寫一個爬蟲的練手項目，基本想法是把某新聞網站的內容分類爬取下來，保存至數據庫，再通過接口對外輸出（提供後臺查詢接口）。那麽問題就來了，python到底是怎麽去操作數據庫的呢？我們今天就來

python3入門教程（二）操作資料庫（一）

概述 　　最近在準備寫一個爬蟲的練手專案，基本想法是把某新聞網站的內容分類爬取下來，儲存至資料庫，再通過介面對外輸出（提供後臺查詢介面）。那麼問題就來了，python到底是怎麼去操作資料庫的呢？我們今天就來研究下。   準備 我這邊資料庫使用的是mysql5.7，python去操作mysql

python3入門教程（二）操作資料庫一

import pymysql # 獲取連線 引數（資料庫IP,埠，使用者名稱,密碼,資料庫名稱，編碼格式） conn = pymysql.connect(host='127.0.0.1', port=3306,user='root', passwd='123456', db='news', charset

eShopOnContainers學習系列（二）：數據庫連接健康檢查

技術分享 負載 star bsp 方法 containe 需要 正常 連接 項目裏使用數據庫的時候，我們有時候需要知道數據庫當前的健康狀態，特別是當數據庫連接不上的時候能夠立馬獲悉。eShopOnContainers裏存在著大量的服務健康、連接健康的檢查，數據庫連接是其中之

Redux 入門教程（二）：中介軟體與非同步操作

上一篇文章，我介紹了 Redux 的基本做法：使用者發出 Action，Reducer 函式算出新的 State，View 重新渲染。 但是，一個關鍵問題沒有解決：非同步操作怎麼辦？Action 發出以後，Reducer 立即算出 State，這叫做同步；Action 發出以後，過一段時間再執行

CodeArt入門教程（二）

本質 文件夾 不同的 存在 切換數據庫 站點 ear 新的 組裝 4.第一個示例的編碼工作 　　使用CA編碼項目的核心結構是：由多個子系統組成多個不同的服務來提供項目的各種功能。請不要將這裏提到的子系統與大家在別的項目實施方法裏的概念混為一談，CA裏的子系統概念是完全不一樣

Dapper入門教程（二）——執行非查詢語句

文本 resp -exec factor -h spa onf fec table 描述 你可以從任意實現IDbConnection的類對象中調用Dapper的擴展方法“Execute”。它能夠執行一條命令（Command）一次或者多次，並返回受影響的行數。這個方法通常用來

Python入門教程（二）

ack 布爾代數 記事本 成對 .py 語法錯誤 是什麽 ech eclips 　　今天講編程思維。　　可能這對初次接觸編程的人有用——我不是不想切入正題，我只是想強調根本沒什麽正題，我可能在其他文章裏提過這一點。“編程語言就是語法糖”，可能你不知道什麽是語法糖，但是知道的

JavaScript基礎入門教程（二）

alert .get OS 全部 isnan rep mut 分別是 只有一個 說明 　　前一篇博客介紹了js以及一些關於js基本類型的簡單知識，本篇博客將詳細介紹js的基礎類型，捎帶介紹對象類型，更詳細的對象類型的說明將後續再講。 js中類型的說明 　　js中的類型分

Linux小小白入門教程（二）：Linux系統安裝

學些Linux最好的方式就是實際操作一番。所以安裝Linux是必然，否則永遠學不會。考慮到學習的方便性，我們將會使用虛擬機器來安裝Linux作業系統。 下載CentOS7系統映象 為了降低大家學習成本，建議大家安裝的Linux版本統一為Centos 7 。下載地址自

CMake入門教程（二）

1、使用set進行變數設定 之前使用：aux_source_directory命令將目錄下的所有.cpp檔案儲存到變數裡面，這樣，我們就不用一個一個去新增原始檔來生成可執行檔案，其實我們使用set命令也可以完成此操作。 #將untile.h以及untile.cpp兩個檔案新增到SrcPa

LimeSDR新手入門教程（二）

上一期我們講解了LimeSDR的基本構造以及簡單的測試，這一期我們來講基本的使用 首先我們需要下載並安裝Pothos(https://github.com/pothosware/PothosCore/wiki/Downloads)，安裝時會有一個詢問安裝部件的

Elastic Job 入門教程（二）— Spring Boot框架下是實現Elastic Job 指令碼作業（Script Job）

在Elastic Job 入門教程（一）— 與Spring Boot整合這篇文章中，我們簡單介紹了Spring Boot與Elastic Job 的整合，並簡單實現了SimpleJob型別作業。本章，我

OpenMP入門教程（二）

OpenMP API概述 OpenMP由三部分組成： 編譯指令（19） 執行時庫程式（32） 環境變數（9） 後來的API包含同樣的三個元件，只是三者的數量都有所增加。   編譯器指令 OpenMP編譯器指令用於各種目的： 產生平行區域 線上程之間劃分程式碼

Unity Shader入門教程（二） ：實現頂點和片元著色器之間的通訊

這篇文章將介紹Pass{}內的程式碼的編寫。我們先看如下Unity Shader程式碼：（此文部分採自《unity shader入門精要》） 關於頂點著色器和片元著色器不懂的學習可以自行搜尋概念的意思，這裡就不介紹了。 Shader "Custom/myTest" {

Docker入門教程（二）命令

【編者的話】DockerOne組織翻譯了Flux7的Docker入門教程，本文是系列入門教程的第二篇，介紹了Docker的基本命令以及命令的用法和功能。 在Docker系列教程的第一篇文章中，我們瞭解了Docker的基礎知識，知道了它是如何工作以及如何安裝的。在這篇文章中，我

Python-matplotlib-入門教程（二）-plot-figure設定

0.摘要 本文主要介紹使用matplotlib畫圖時使用的配置方法，並對配置引數進行解釋。   1.pyplot.figure() 用於建立一個新的圖。函式引數如下： figure(num=None, figsize=None, dpi=None, facecolor=

Git-入門教程（二）-Linux、MacOS和Windows下安裝與使用

0.摘要 本文主要介紹在Linux、MacOS和Windows三種系統下Git的安裝與使用，具體的Git命令和詳細使用方法在其他部落格中講解。 1.Linux下的安裝與使用 CentOS：使用yum安裝git yum install -y git -y引數：安裝

在.Net Core中使用MongoDB的入門教程（二）

在上一篇文章中，講到了MongoDB在匯入驅動、MongoDB的連線，資料的插入等。 本篇文章將接著上篇文章進行介紹MongoDB在.Net Core中的使用，建議看這篇文章之前，先看上面一篇文章。 另外，今天在安裝MongoDB資料庫的時候，居然卡在了下一步幾乎花了兩三

IOS 初級開發入門教程（二）第一個HelloWorld工程及StoryBoard使用

前言 在IOS開發之路的博文第一章：(IOS開發入門介紹http://blog.csdn.net/csdn_aiyang）我大致系統介紹了有關IOS的一些基礎認識，如果不完全都記住沒關係，以後我們開發之路還很長，慢慢的自然而然就明白是怎麼回事了。這一篇我將手把手教大家完成第