2. 程式人生 > >python3基礎：操作mysql資料庫

python3基礎：操作mysql資料庫

阿新 • • 發佈：2018-12-25

mysql登陸

基本操作：
登陸：mysql -uroot -h127.0.0.1 -P3306 -p
mysql -uroot -p(本機不用寫host)
退出mysql：ctrl+z+回車，或者exit
埠號預設是3306，但是可以通過安裝目錄下的配置檔案修改。

使用流程

  • 引用API模組
  • 獲取與資料庫的連線
  • 執行sql語句與儲存過程
  • 關閉資料庫連線

安裝pymysql

python3 與MySQL 進行互動程式設計需要安裝 pymysql 庫，故首先使用如下命令安裝pymysql
–>pip install pymysql
如果電腦中py2和py3共存的話，安裝失敗時請參考之前的部落格

安裝方法

pymysql.connect()連線資料庫函式

程式碼示例：

import pymysql
#開啟資料庫連線
conn = pymysql.connect('localhost',user = "root",passwd = "123456",db = "testdb")
print (conn)
print (type(conn))

在這裡插入圖片描述

conn.cursor():獲取遊標

要想操作資料庫，光連線資料是不夠的，必須拿到操作資料庫的遊標，才能進行後續的操作，比如讀取資料、新增資料。通過獲取到的資料庫連線例項conn下的cursor()方法來建立遊標。遊標用來接收返回結果
程式碼示例：

import pymysql
#開啟資料庫連線
conn = pymysql.connect('localhost',user = "root",passwd = "123456",db = "testdb")
#獲取遊標
cursor=conn.cursor()
print(cursor)

在這裡插入圖片描述
說明：cursor返回一個遊標例項物件，其中包含了很多操作資料的方法，比如執行sql語句。

執行sql語句execute和executemany

  • execute(query,args=None)
  • 函式作用：執行單條的sql語句，執行成功後返回受影響的行數
  • 引數說明：
    query
    ：要執行的sql語句，字串型別
    args：可選的序列或對映，用於query的引數值。如果args為序列，query中必須使用%s做佔位符；如果args為對映，query中必須使用%(key)s做佔位符
  1. executemany(query,args=None)
  • 函式作用：批量執行sql語句，比如批量插入資料，執行成功後返回受影響的行數
  • 引數說明：
    query：要執行的sql語句，字串型別
    args：巢狀的序列或對映，用於query的引數值

注意：
1.資料庫效能瓶頸很大一部份就在於網路IO和磁碟IO，將多個sql語句放在一起，只執行一次IO，可以有效的提升資料庫效能。推薦此方法
2.用executemany()方法一次性批量執行sql語句，固然很好，但是當資料一次傳入過多到server端，可能造成server端的buffer溢位，也可能產生一些意想不到的麻煩。所以，合理、分批次使用executemany是個合理的辦法

建立資料庫

程式碼示例：

'''建立資料庫'''
import pymysql
#開啟資料庫連線，不需要指定資料庫，因為需要建立資料庫
conn = pymysql.connect('localhost',user = "root",passwd = "123456")
#獲取遊標
cursor=conn.cursor()
#建立pythonBD資料庫
cursor.execute('CREATE DATABASE IF NOT EXISTS pythonDB DEFAULT CHARSET utf8 COLLATE utf8_general_ci;')
cursor.close()#先關閉遊標
conn.close()#再關閉資料庫連線
print('建立pythonBD資料庫成功')

在這裡插入圖片描述

建立表

程式碼示例：

import pymysql
#開啟資料庫連線
conn = pymysql.connect('localhost',user = "root",passwd = "123456",db = "testdb")
#獲取遊標
cursor=conn.cursor()
print(cursor)

#建立user表
cursor.execute('drop table if exists user')
sql="""CREATE TABLE IF NOT EXISTS `user` (
	  `id` int(11) NOT NULL AUTO_INCREMENT,
	  `name` varchar(255) NOT NULL,
	  `age` int(11) NOT NULL,
	  PRIMARY KEY (`id`)
	) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""

cursor.execute(sql)
cursor.close()#先關閉遊標
conn.close()#再關閉資料庫連線
print('建立資料表成功')

插入單條資料

程式碼示例：

'''插入單條資料'''
import pymysql
#開啟資料庫連線，不指定資料庫
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')

cur=conn.cursor()#獲取遊標

#建立user表
cur.execute('drop table if exists user')
sql="""CREATE TABLE IF NOT EXISTS `user` (
	  `id` int(11) NOT NULL AUTO_INCREMENT,
	  `name` varchar(255) NOT NULL,
	  `age` int(11) NOT NULL,
	  PRIMARY KEY (`id`)
	) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""

cur.execute(sql)

insert=cur.execute("insert into user values(1,'tom',18)")
print('新增語句受影響的行數：',insert)

#另一種插入資料的方式，通過字串傳入值
sql="insert into user values(%s,%s,%s)"
cur.execute(sql,(3,'kongsh',20))

cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述

批量插入多條資料

程式碼示例：

'''插入多條資料'''
import pymysql
#開啟資料庫連線，不指定資料庫
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#獲取遊標
cur=conn.cursor()

#另一種插入資料的方式，通過字串傳入值
sql="insert into user values(%s,%s,%s)"
insert=cur.executemany(sql,[(4,'wen',20),(5,'tom',10),(6,'test',30)])
print ('批量插入返回受影響的行數：',insert)
cur.close()
conn.commit()
conn.close()
print('sql執行成功')

注意：批量插入多條sql語句採用的是executemany(sql,args)函式，返回受影響的行數。args引數是一個包含多個元組的列表，每個元組對應一條mysql中的一條資料。這裡的%s不需要加引號，否則插入資料的資料會型別錯誤

查詢資料

使用execute()函式得到的只是受影響的行數，並不能真正拿到查詢的內容。cursor物件還提供了3種提取資料的方法：fetchone、fetchmany、fetchall.。每個方法都會導致遊標動，所以必須注意遊標的位置。
cursor.fetchone():獲取遊標所在處的一行資料，返回元組，沒有返回None
cursor.fetchmany(size):接受size行返回結果行。如果size大於返回的結果行的數量，則會返回cursor.arraysize條資料。
cursor. fetchall():接收全部的返回結果行。

程式碼示例：fetchone

'''fetchone'''
import pymysql
#開啟資料庫連線
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#獲取遊標
cur=conn.cursor()

cur.execute("select * from user;")
while 1:
    res=cur.fetchone()
    if res is None:
        #表示已經取完結果集
        break
    print (res)
cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述

注意：從execute()函式的查詢結果中取資料，以元組的形式返回遊標所在處的一條資料，如果遊標所在處沒有資料，將返回空元組，該資料執行一次，遊標向下移動一個位置。fetchone()函式必須跟exceute()函式結合使用，並且在exceute()函式之後使用

程式碼示例：fetchmany
‘’‘fetchmany’’’
import pymysql
#開啟資料庫連線
conn=pymysql.connect(‘localhost’,‘root’,‘123456’)
conn.select_db(‘pythondb’)
#獲取遊標
cur=conn.cursor()

cur.execute(“select * from user”)
#取3條資料
resTuple=cur.fetchmany(3)
print(type(resTuple))
for res in resTuple:
print (res)

cur.close()
conn.commit()
conn.close()
print(‘sql執行成功’)
在這裡插入圖片描述
注意：從exceute()函式結果中獲取遊標所在處的size條資料，並以元組的形式返回，元組的每一個元素都也是一個由一行資料組成的元組，如果size大於有效的結果行數，將會返回cursor.arraysize條資料，但如果遊標所在處沒有資料，將返回空元組。查詢幾條資料，遊標將會向下移動幾個位置。fetmany()函式必須跟exceute()函式結合使用，並且在exceute()函式之後使用

程式碼示例：fetchall
‘’‘fetchall’’’
import pymysql
#開啟資料庫連線
conn=pymysql.connect(‘localhost’,‘root’,‘123456’)
conn.select_db(‘pythondb’)
#獲取遊標
cur=conn.cursor()

cur.execute(“select * from user”)
#取所有資料
resTuple=cur.fetchall()
print(type(resTuple))
print (‘共%d條資料’%len(resTuple))

cur.close()
conn.commit()
conn.close()
print(‘sql執行成功’)
在這裡插入圖片描述

注意：獲取遊標所在處開始及以下所有的資料，並以元組的形式返回，元組的每一個元素都也是一個由一行資料組成的元組，如果遊標所在處沒有資料，將返回空元組。執行完這個方法後，遊標將移動到資料庫表的最後

更新資料

程式碼示例：更新單條資料

'''更新單條資料'''
import pymysql
#開啟資料庫連線
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#獲取遊標
cur=conn.cursor()

#更新一條資料
update=cur.execute("update user set age=100 where name='kongsh'")
print ('修改後受影響的行數為：',update)
#查詢一條資料
cur.execute(select * from user where name="kongsh";')
print(cur.fetchone())
cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述
程式碼示例：更新多條資料

'''更新多條資料'''
import pymysql
#開啟資料庫連線
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#獲取遊標
cur=conn.cursor()

#更新前查詢所有資料
cur.execute("select * from user where name in ('kongsh','wen');")
print('更新前的資料為：')
for res in cur.fetchall():
      print (res)

print ('*'*40)      
#更新2條資料
sql="update user set age=%s where name=%s"
update=cur.executemany(sql,[(15,'kongsh'),(18,'wen')])

#更新2條資料後查詢所有資料
cur.execute("select * from user where name in ('kongsh','wen');")
print('更新後的資料為：')
for res in cur.fetchall():
      print (res)


cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述

刪除資料

程式碼示例：刪除單條資料

'''刪除單條資料'''
import pymysql
#開啟資料庫連線
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#獲取遊標
cur=conn.cursor()

#刪除前查詢所有資料
cur.execute("select * from user;")
print('刪除前的資料為：')
for res in cur.fetchall():
      print (res)

print ('*'*40)      
#刪除1條資料
cur.execute("delete from user where id=1")

#刪除後查詢所有資料
cur.execute("select * from user;")
print('刪除後的資料為：')
for res in cur.fetchall():
      print (res)
cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述
程式碼示例：刪除多條資料

'''刪除多條資料'''
import pymysql
#開啟資料庫連線
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#獲取遊標
cur=conn.cursor()

#刪除前查詢所有資料
cur.execute("select * from user;")
print('刪除前的資料為：')
for res in cur.fetchall():
      print (res)

print ('*'*40)      
#刪除2條資料
sql="delete from user where id=%s"
cur.executemany(sql,[(3),(4)])

#刪除後查詢所有資料
cur.execute("select * from user;")
print('刪除後的資料為：')
for res in cur.fetchall():
      print (res)
cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述

事務回滾

程式碼示例：’’‘事務回滾’’'

import pymysql
#開啟資料庫連線
conn=pymysql.connect('localhost','root','123456')
conn.select_db('pythondb')
#獲取遊標
cur=conn.cursor()

#修改前查詢所有資料
cur.execute("select * from user;")
print('修改前的資料為：')
for res in cur.fetchall():
      print (res)

print ('*'*40)      
#更新表中第1條資料
cur.execute("update user set name='xiaoxiaoxiaoxiaoren' where id=5")

#修改後查詢所有資料
cur.execute("select * from user;")
print('修改後的資料為：')
for res in cur.fetchall():
      print (res)
print ('*'*40)
#回滾事務
conn.rollback()
cur.execute("select * from user;")
print('回滾事務後的資料為：')
for res in cur.fetchall():
      print (res)

cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述

練習：插入100條資料到資料庫

程式碼示例：每次插入一條

'''插入100條資料到資料庫(每次插入一條)'''
import pymysql
import string,random
#開啟資料庫連線
conn=pymysql.connect('localhost','root','123456')
conn.select_db('testdb')
#獲取遊標
cur=conn.cursor()

#建立user表
cur.execute('drop table if exists user')
sql="""CREATE TABLE IF NOT EXISTS `user` (
	  `id` int(11) NOT NULL AUTO_INCREMENT,
	  `name` varchar(255) NOT NULL,
	  `age` int(11) NOT NULL,
	  PRIMARY KEY (`id`)
	) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""

cur.execute(sql)

#修改前查詢所有資料
cur.execute("select * from user;")
print('修改前的資料為：')
for res in cur.fetchall():
      print (res)

print ('*'*40)      
#迴圈插入資料
words=list(string.ascii_letters)
sql="insert into user values(%s,%s,%s)"
for i in range(100):
      random.shuffle(words)#打亂順序
      cur.execute(sql,(i+1,"".join(words[:5]),random.randint(0,80)))

#插入100條後查詢所有資料
cur.execute("select * from user;")
print('修改後的資料為：')
for res in cur.fetchall():
      print (res)
print ('*'*40)

cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述
程式碼示例：一次插入多條

'''插入100條資料到資料庫(一次插入多條)'''
import pymysql
import string,random
#開啟資料庫連線
conn=pymysql.connect('localhost','root','123456')
conn.select_db('testdb')
#獲取遊標
cur=conn.cursor()

#建立user表
cur.execute('drop table if exists user')
sql="""CREATE TABLE IF NOT EXISTS `user` (
	  `id` int(11) NOT NULL AUTO_INCREMENT,
	  `name` varchar(255) NOT NULL,
	  `age` int(11) NOT NULL,
	  PRIMARY KEY (`id`)
	) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=0"""

cur.execute(sql)

#修改前查詢所有資料
cur.execute("select * from user;")
print('修改前的資料為：')
for res in cur.fetchall():
      print (res)

print ('*'*40)      
#迴圈插入資料
words=list(string.ascii_letters)
sql="insert into user values(%s,%s,%s)"
random.shuffle(words)#打亂順序
cur.executemany(sql,[(i+1,"".join(words[:5]),random.randint(0,80)) for i in range(100) ])

#插入100條後查詢所有資料
cur.execute("select * from user;")
print('修改後的資料為：')
for res in cur.fetchall():
      print (res)
print ('*'*40)

cur.close()
conn.commit()
conn.close()
print('sql執行成功')

在這裡插入圖片描述

相關推薦

python3基礎：操作mysql資料庫

mysql登陸 基本操作： 登陸：mysql -uroot -h127.0.0.1 -P3306 -p mysql -uroot -p(本機不用寫host) 退出mysql：ctrl+z+回車，或者exit 埠號預設是3306，但是可以通過安裝目錄下的配置檔案修改。 使用流程

python3基礎：操作xml

XML 指的是可擴充套件標記語言(eXtensible Markup Language)，和json類似也是用於儲存和傳輸資料，還可以用作配置檔案。類似於HTML超文字標記語言，但是HTML所有的標籤都是預定義的，而xml的標籤可以隨便定義。 XML元素 指從開始標籤到結束標籤的部分

python3基礎：操作json

json是java script object notation的縮寫，用來儲存和交換文字資訊，比xml更小/更快/更易解析，易於讀寫，佔用頻寬小，網路傳輸速度快的特性，適用於資料量大，不要求保留原有型別的情況。 json語法規則 資料在名稱/值對中 資料用逗號分隔 花括號儲存

python3+ 連線並操作mysql 資料庫,支援讀寫分離

最近，看了關於的一篇帖子，關於python的，決定花幾天看下python的基本知識。看了基礎知識後，發現記不住，就隨手寫了點程式碼，加深自己的記憶。 暫時主要寫了對資料庫的操作，其他的都還沒有做，後續會逐步完善，程式碼寫的很基礎，裡面肯定還存在很多問題，自己儲存起，怕後面丟

Python3操作MySQL資料庫(驅動：pymysql)

建庫建表 create database wuSir default character set utf8 collate utf8_general_ci; use wuSir; create table auth_info( aid int

python3基礎：檔案操作

相對路徑和絕對路徑 相對路徑：顧名思義就是相對於當前檔案的路徑。網頁中一般表示路徑使用這個方法。 絕對路徑：絕對路徑就是主頁上的檔案或目錄在硬碟上真正的路徑。 比如 c:/apache/cgi-bin 下的，那麼 c:/apache/cgi-bin就是cgi-bin目錄的絕對路徑 檔

python3基礎：目錄操作

目錄操作 os模組提供了統一的作業系統介面函式，python中對檔案和資料夾的操作都要涉及到os和shutil模組，在使用前需要使用import引入，例如; import os import os.path import shutil   os.getcwd()

報錯處理：Python操作Mysql資料庫插入中文錯誤

學習《python網路爬蟲從入門到實踐》中遇到以下錯誤： Incorrect string value: '\xE7\xA8\x8B\xE5\xBA\x8F...' for column 'course' at row 1 出現這個錯誤的原因是，資料庫的編碼格式為latin1 而我要將utf

除錯環境python3.6，除錯python操作mysql資料庫

python3.6下程式碼如下 #coding:utf-8 #python3.6使用pymysql操作mysql print("=====================mysql資料庫=====================") import pymysql.cursors # 連

python3 操作mysql資料庫

著急下班，直接上程式碼，有時間回來補充說明： pymysql 為第三方包，使用前需要自行安裝，我直接聯網安裝的，當然，也可以使用原始碼安裝，根據個人情況而定。 pymysql 主要步驟為：1. 得到連結，拿到遊標（通過連結，得到cursor()）， 2. 通過cursor,呼叫execute方法執行sq

python3用pymysql連線mysql資料庫進行操作

原創文章，轉載請註明出處 pymysql是python3特有的，python2沒有，只能用mysqldb 需提前建好資料庫和對應的表 第一步，安裝pymysql pip install PyMySQL 第二步，資料庫連線及獲得遊標物件 cursor # 開啟資料庫連線 db

JAVA通過JDBC操作MySQL資料庫（三）：PreparedStatement介面操作資料庫

JAVA通過JDBC操作MySQL資料庫（三）：PreparedStatement介面操作資料庫 Statement介面的問題 PreparedStatement介面操作資料庫 Statement介面的問題 在文章JAVA通過JDBC操作

python3使用pymysql連線Mysql 資料庫及 簡單的增刪改查操作

示例表1查詢操作import pymysql #匯入 pymysql #開啟資料庫連線 db= pymysql.connect(host="localhost",user="root", password="123456",db="test",po

python3操作MySQL資料庫

這是python3下的MySQL基本操作。其他型別的資料庫用法基本一樣。就是庫的名字不同。因為python官方很早之前就規定了資料庫第三方庫的藉口，來避免API混亂的情況。 安裝與準備 這是python3的庫，所以windows下安裝不會像python2那樣各種奇葩V

python3操作mysql資料庫增刪改查

python3.x 使用pymysql操作mysql，python2.x使用mysqldb操作mysql #!/usr/bin/python3 import pymysql import type

操作MySQL資料庫報出：Parameter index out of range (1 > number of parameters, which is

對MySQL進行insert操作，控制檯丟擲以下錯誤：Parameter index out of range (1 > number of parameter

python3通過pymysql連線MySQL資料庫操作

python連線MySQL資料庫 所需要的工具： PyCharm pymysql外掛 MySQL資料庫 安裝pymysql外掛 在PyCharm中依次點選file->setting->project xxx ->project

Python3 pymysql操作mysql資料庫（一）

一. 連線mysql : pymysql.connect()import pymysql # 連線資料庫 conn = pymysql.connect(host='127.0.0.1', user='***', # 資料庫使用

用php操作mysql資料庫：在web頁面顯示查詢內容

初次學習用php操作資料庫，做一做筆記，簡單的總結一下如何在web介面輸出查詢內容和向資料庫中新增記錄。如有錯誤，望評論指正。 就是用php巢狀HTML程式碼，用一個table輸出。 在學習中遇到一些問題： 1.PHP無法向MYSQL插入中文記錄 如果在sql語句裡面插

MySQL基礎知識：建立MySQL資料庫和表

虛構一個微型線上書店的資料庫和資料，作為後續MySQL指令碼的執行源，方便後續MySQL和SQL的練習。 在虛構這個庫的過程中，主要涉及的是如何使用命令列管理 ```MySQL```資料庫物件：資料庫、表、索引、外來鍵等；另一個更為重要的是如何Mock對應表的資料。 **虛構書店資料庫的dump指令碼**