【語法14】Python-mysql-connector驅動

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

MySQL 是最流行的關係型資料庫管理系統。

本章節我們為大家介紹使用 mysql-connector 來連線使用 MySQL， mysql-connector 是 MySQL 官方提供的驅動器。

我們可以使用 pip 命令來安裝 mysql-connector：

python3 -m pip install mysql-connector

使用以下程式碼測試 mysql-connector 是否安裝成功：

import mysql.connector

執行以上程式碼，如果沒有產生錯誤，表明安裝成功。

建立資料庫連線

import mysql.connector

mydb = mysql.connector. 
connect(
  host="localhost",       # 資料庫主機地址
  user="root",    # 資料庫使用者名稱
  passwd=""   # 資料庫密碼
)
 
print(mydb)

<mysql.connector.connection.MySQLConnection object at 0x0000019D2E6457F0>

#建立資料庫

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = 
 '',
)

mycursor = mydb.cursor()

mycursor.execute("CREATE DATABASE test2_db")

mycursor.execute("SHOW DATABASES")

for x in mycursor:
    print(x)

('information_schema',)
('mysql',)
('performance_schema',)
('sys',)
('test1_db',)
('test2_db',)
('test_db',)

#或者我們可以直接連線資料庫，如果資料庫不存在，會輸出錯誤資訊

import mysql. 
connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db'
)

建立資料表

# 建立資料表

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("CREATE TABLE test(name VARCHAR(255),url VARCHAR(255))")

#顯示資料表

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SHOW TABLES")

for x in mycursor:
    print(x)

('test',)

#設定主鍵

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("ALTER TABLE test ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY")

在這裡插入圖片描述

插入資料

#插入一條記錄
import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

sql = "INSERT INTO test (name,url) VALUES (%s,%s)"
val = ("ECUST","Xu Huan")
mycursor.execute(sql,val)

mydb.commit()

print(mycursor.rowcount,'記錄插入成功')

1 記錄插入成功

#插入多條記錄
import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

sql = "INSERT INTO test (name,url) VALUES (%s,%s)"
val = [("ECUST","Xu Huan"),
      ("MIT","Wang Yizhuo"),
      ("JHU","Nawukere"),
      ]
mycursor.executemany(sql,val)#使用executemany()插入多條記錄

mydb.commit()

print(mycursor.rowcount,'記錄插入成功')

3 記錄插入成功

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

sql = "INSERT INTO test (name,url) VALUES (%s,%s)"
val = [("PKU","Smith"),
      ]
mycursor.executemany(sql,val)

mydb.commit()

print('一條記錄已插入',mycursor.lastrowid)

一條記錄已插入 7

在這裡插入圖片描述

查詢資料

#查詢資料可以用SELECT語句

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM test")

myresult = mycursor.fetchall() #fetchall()獲取所有記錄

for i in myresult:
    print(i)

('ECUST', 'Xu Huan', 1)
('ECUST', 'Xu Huan', 2)
('ECUST', 'Xu Huan', 3)
('MIT', 'Wang Yizhuo', 4)
('JHU', 'Nawukere', 5)
('PKU', 'Smith', 6)
('PKU', 'Smith', 7)

#也可以讀取指定的欄位資料

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SELECT name,id FROM test")

myresult = mycursor.fetchall()

for i in myresult:
    print(i)

('ECUST', 1)
('ECUST', 2)
('ECUST', 3)
('MIT', 4)
('JHU', 5)
('PKU', 6)
('PKU', 7)

#如果只想讀取一條資料，可以使用fetchone()方法

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM test")

myresult = mycursor.fetchone() 

print(myresult)

('ECUST', 'Xu Huan', 1)

#對讀取的資料有條件限制，可以使用where語句

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM test WHERE name = 'ECUST'")

myresult = mycursor.fetchall() 

for i in myresult:
    print(i)

('ECUST', 'Xu Huan', 1)
('ECUST', 'Xu Huan', 2)
('ECUST', 'Xu Huan', 3)

#也可以使用萬用字元%

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM test WHERE name LIKE '%K%'")

myresult = mycursor.fetchall() 

for i in myresult:
    print(i)

('PKU', 'Smith', 6)
('PKU', 'Smith', 7)

#為了防止資料庫查詢發生SQL注入的攻擊，可以使用%s佔位符轉義查詢的條件

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

sql = "SELECT * FROM test WHERE name = %s"
na = ('PKU',)

mycursor.execute(sql, na)

myresult = mycursor.fetchall() 

for i in myresult:
    print(i)

('PKU', 'Smith', 6)
('PKU', 'Smith', 7)

#排序

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM test ORDER BY url")

myresult = mycursor.fetchall() 

for i in myresult:
    print(i)

('JHU', 'Nawukere', 5)
('PKU', 'Smith', 6)
('PKU', 'Smith', 7)
('MIT', 'Wang Yizhuo', 4)
('ECUST', 'Xu Huan', 1)
('ECUST', 'Xu Huan', 2)
('ECUST', 'Xu Huan', 3)

#對資料基於某屬性降序排序

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM test ORDER BY name DESC")

myresult = mycursor.fetchall() 

for i in myresult:
    print(i)

('PKU', 'Smith', 6)
('PKU', 'Smith', 7)
('MIT', 'Wang Yizhuo', 4)
('JHU', 'Nawukere', 5)
('ECUST', 'Xu Huan', 1)
('ECUST', 'Xu Huan', 2)
('ECUST', 'Xu Huan', 3)

#讀取指定數量條資料
#限制讀取資料起始資料
import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("SELECT * FROM test LIMIT 4 OFFSET 2")
#用LIMIT語句指定查詢資料量
#用OFFSET語句限制起始位置

myresult = mycursor.fetchall() 

for i in myresult:
    print(i)

('ECUST', 'Xu Huan', 3)
('MIT', 'Wang Yizhuo', 4)
('JHU', 'Nawukere', 5)
('PKU', 'Smith', 6)

刪除記錄

#使用DELETE FROM語句刪除記錄
import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

mycursor.execute("DELETE FROM test WHERE name LIKE '%K%'")

mydb.commit()
 
print(mycursor.rowcount, " 條記錄刪除")

2  條記錄刪除

#為了防止資料庫查詢發生 SQL 注入的攻擊，我們可以使用 %s 佔位符來轉義刪除語句的條件

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

sql = "DELETE FROM test WHERE name = %s"
na = ("ECUST",)

mycursor.execute(sql,na)

mydb.commit()
 
print(mycursor.rowcount, " 條記錄刪除")

3  條記錄刪除

更新表資料

import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()


sql = "UPDATE test SET name = 'princeton' WHERE name = 'JHU'"
 
mycursor.execute(sql)

mydb.commit()

print(mycursor.rowcount,'條記錄被修改')

2 條記錄被修改

#為了防止資料庫查詢發生 SQL 注入的攻擊，我們可以使用 %s 佔位符來轉義更新語句的條件
import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()


sql = "UPDATE test SET name = %s WHERE name = %s"
na = ('JHU','princeton')
 
mycursor.execute(sql,na)

mydb.commit()

print(mycursor.rowcount,'條記錄被修改')

2 條記錄被修改

刪除表

#使用DROP TABLE語句刪除表，使用IF EXISTS關鍵字判斷表是否尊在
import mysql.connector

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '',
    database = 'test_db',
)

mycursor = mydb.cursor()

sql = 'DROP TABLE IF EXISTS test'

mycursor.execute(sql)

在這裡插入圖片描述

【語法14】Python-mysql-connector驅動

MySQL 是最流行的關係型資料庫管理系統。本章節我們為大家介紹使用 mysql-connector 來連線使用 MySQL， mysql-connector 是 MySQL 官方提供的驅動器。我們可以使用 pip 命令來安裝 mysql-connector

【語法01】Python基本語法.md

基本語法 #Python保留字 import keyword keyword.kwlist ['False', 'None', 'True', 'and', 'as', 'assert', 'break', 'class', 'continue

【語法02】Python資料型別

數字（Number） # 使用del語句刪除一些數字物件的引用 # del var1[,var2[,var3[....,varN]]]] # 通過使用del語句刪除單個或多個物件的引用 # del var # del var_a, var_b #Pytho

【語法03】Python基本語句

條件控制 ''' if condition_1: statement_block_1 elif condition_2: statement_block_2 else: statement_block_3 ''' a = 'Xuhuan

【語法07】Python檔案方法

open()方法 Python open() 方法用於開啟一個檔案，並返回檔案物件，在對檔案進行處理過程都需要使用到這個函式，如果該檔案無法被開啟，會丟擲 OSError。 ''' 注意：使用 open() 方法一定要保證關閉檔案物件，即呼叫 close() 方

【語法09】Python錯誤和異常

作為Python初學者，在剛學習Python程式設計時，經常會看到一些報錯資訊，在前面我們沒有提及，這章節我們會專門介紹。 Python有兩種錯誤很容易辨認：語法錯誤和異常。語法錯誤 ''' Python 的語法錯誤或者稱之為解析錯，是初學者經常碰到的，如下例

【語法12】Python正則表示式

正則表示式正則表示式是一個特殊的字元序列，它能幫助你方便的檢查一個字串是否與某種模式匹配。 Python 自1.5版本起增加了re 模組，它提供 Perl 風格的正則表示式模式。 re 模組使 Python 語言擁有全部的正則表示式功能。 compile 函式

【轉】python mysql數據庫 'latin-1' codec can't encode character錯誤問題解決

處理 tin sql數據庫 clas question ack RM can 意思 UnicodeEncodeError: ‘latin-1‘ codec can‘t encode character "UnicodeEncodeError:‘latin-1‘ co

【自動化測試】Python 訪問 mysql資料庫

一、準備工作 1、確保Python環境已安裝mysql，py3.*版本：pip install PyMySQL PyMySQL是在Python3.x中用於連線MySQL伺服器的一個庫。 2、已經建立了資料庫testDB，相關表table，以及表字段 3、資料庫連線

【轉】Python mysql 引數替換的坑

文章轉自 https://blog.xupeng.me/2013/09/25/mysqldb-args-processing/ 感謝原作者分享前幾天又有同事掉進了給 SQL 的 IN 條件傳參的坑，就像 SELECT col1, col2 FROM tab

【已解決】Python指令碼執行出現語法錯誤：IndentationError: unindent does not match any outer indentation level

原創出處：http://www.crifan.com/python_syntax_error_indentationerror/comment-page-1/ 【問題】一個python指令碼，本來都執行好好的，然後寫了幾行程式碼，而且也都確保每行都對齊了，但是執行的

【嘔心總結】python如何與mysql實現互動及常用sql語句

9 月初，我對 python 爬蟲燃起興趣，但爬取到的資料多通道實時同步讀寫用檔案並不方便，於是開始用起mysql。這篇筆記，我將整理近一個月的實戰中最常用到的 mysql 語句，同時也將涉及到如何在python3中與 mysql 實現資料交換。關於工具/庫，特別說明下： 1、我安裝了 mysql ，並直

【匯總】Python 編程核心知識體系

目前博客列表修改 pic http 匯總 -- elf 【匯總】Python 編程核心知識體系大神著作，源自：https://woaielf.github.io/2017/06/13/python3-all/ 本文主要涵蓋了 Python 編程的核心知識（暫不包括標

【面試題】Python高級開發工程師面試題

http ges log com .com blog mage 回復 image 線上面試題，有空整理答案，歡迎大家回復答案【面試題】Python高級開發工程師面試題

【COGS 14】 [網絡流24題] 搭配飛行員網絡流板子題

str main head fin i++ add pri can tail 用網絡流水二分圖的模型（存一下板子） #include <cstdio> #include <cstring> #include <algorithm> #d

【學習筆記】python爬取百度真實url

python 今天跑個腳本需要一堆測試的url，，，挨個找復制粘貼肯定不是程序員的風格，so，還是寫個腳本吧。環境：python2.7 編輯器：sublime text 3 一、分析一下首先非常感謝百度大佬的url分類非常整齊，都在一個

【小工具】python 連接redis查詢

python redis 查詢作用說明：通過python連接redis進行查詢，判斷結果並進行後續操作。需先安裝redis-2.10.5.tar.gz。代碼如下：#!/usr/local/bin/python import redis r = redis.StrictRedis(host=‘192.168.1

【小工具】python 在服務器上臨時啟用一個端口

python socket 啟用端口在服務器還未部署應用，而這時候如果要驗證網絡是否開通，我們可以先在服務器上模擬啟用應用的端口，然後從其他地方telnet這個端口來驗證網絡的開通情況。這邊使用python腳本來臨時啟用一個端口，用於測試使用。腳本如下：import socket while True:

Python之路【第一篇】:Python簡介和入門

源碼 world 網絡服務換行編程風格大小寫 utf8 編譯安裝比較 python簡介：一、什麽是python Python（英國發音：/ pa θ n/ 美國發音：/ pa θɑ n/），是一種面向對象、直譯式的計算機程序語言。每一門語言都有自己的哲學： py

【學習筆記】python 進階特性

可能 pytho red nbsp python blog 有一個自省 blue __slots__魔法在Python中，每個類都有實例屬性。默認情況下Python用一個字典來保存一個對象的實例屬性。這非常有用，因為它允許我們在運行時去設置任意的新屬性。然而，對於有

【語法14】Python-mysql-connector驅動

建立資料庫連線

建立資料表

插入資料

查詢資料

刪除記錄

更新表資料

刪除表

相關推薦