python與mysql連接

㈠ python 進階知識全篇-Python Mysql - mysql-connector

MySQL 是廣泛使用的資料庫管理系統，如果你對 MySQL 不夠熟悉，建議先閱讀我們的 MySQL 教程。此教程將帶你深入了解如何通過 mysql-connector 來連接和操作 MySQL。

mysql-connector 是 MySQL 官方提供的驅動程序，能夠幫助你輕松實現 Python 與 MySQL 之間的交互。你只需要使用 pip 命令安裝它，具體命令如下：

python -m pip install mysql-connector

為驗證安裝是否成功，可以嘗試運行以下測試代碼：

import mysql.connector

執行此代碼後若未出現錯誤提示，說明安裝已成功。

若你的 MySQL 版本為 8.0，則需注意密碼驗證方式已從 mysql_native_password 更改為 caching_sha2_password。因此，在安裝驅動後，還需對 my.ini 配置文件進行修改，並執行相應的 SQL 命令以確保密碼驗證方式符合新版本要求。更多詳細操作，可以參考：闕贊：Python MySQL8.0 錯誤創建資料庫連接。

連接資料庫的操作可以通過以下 Python 代碼實現：

import mysql.connector

嘗試連接資料庫，如果資料庫不存在，代碼將輸出相應的錯誤信息。

資料庫的創建則使用 "CREATE DATABASE" 語句。以下代碼示例創建了一個名為 runoob_db 的資料庫：

創建資料庫前，可以使用 "SHOW DATABASES" 命令查看當前是否存在特定資料庫：

執行此命令後，你將看到資料庫列表。若資料庫已存在，嘗試再次創建將收到錯誤信息。

為了實現數據表的創建，我們使用 "CREATE TABLE" 語句。例如，以下代碼創建了一個名為 sites 的數據表，包含欄位 name 和 url：

執行此代碼後，資料庫中將出現名為 sites 的數據表。

可以使用 "SHOW TABLES" 命令查看數據表是否已成功創建。

通常，我們會為主鍵設置一個 INT AUTO_INCREMENT PRIMARY KEY，確保起始值為 1，並逐步遞增。如果表已創建，可通過 ALTER TABLE 命令添加主鍵。

插入數據的關鍵操作使用 "INSERT INTO" 語句。以下代碼插入了一條數據至 sites 表：

執行後，數據表中應新增一條記錄。

批量插入數據時，利用 executemany() 方法，該方法接收元組列表作為參數，包含要插入的數據。下面代碼示例批量插入多條記錄至 sites 表：

執行後，輸出應為插入記錄成功的信息。

在數據插入後，若需獲取新記錄的 ID，可使用以下代碼：

執行此代碼後，輸出應為插入記錄成功，並顯示其 ID。

查詢數據使用 SELECT 語句，以下代碼示例展示如何獲取 sites 表中的所有數據：

執行後，輸出結果將包含所有記錄。

若僅需讀取特定欄位的數據，可以通過指定欄位來獲取。同樣，利用 SELECT 語句，以下代碼展示如何獲取 sites 表中指定欄位的數據：

執行後，輸出結果將只包含指定欄位。

如果只讀取一條數據，可以使用 fetchone() 方法。以下代碼示例展示如何僅讀取第一條數據：

執行此代碼後，輸出結果應為一條記錄。

使用 where 語句可以讀取特定條件的數據。以下代碼示例讀取 name 欄位為 'SHUAIGEGE' 的記錄：

執行後，輸出結果應為符合條件的記錄。

通配符 % 可以用來匹配包含特定字元串的數據。以下代碼示例讀取包含 'google' 的記錄：

執行後，輸出結果應為包含 'google' 的所有記錄。

為了防止 SQL 注入攻擊，使用 %s 佔位符來轉義查詢條件。以下代碼示例展示如何安全地執行查詢：

執行此代碼後，輸出結果應為安全查詢到的數據。

數據查詢結果可以通過 ORDER BY 語句進行排序，默認為升序，關鍵字為 ASC。若需設置降序排序，使用 DESC 關鍵字。以下代碼示例展示如何按 name 欄位升序排序查詢結果：

執行後，輸出結果應為按 name 欄位升序排序後的所有記錄。

降序排序的實現方法與升序類似，只需將 ASC 替換為 DESC 關鍵字。以下代碼示例展示如何按 name 欄位降序排序查詢結果：

執行後，輸出結果應為按 name 欄位降序排序後的所有記錄。

限制查詢結果的數量可通過 LIMIT 語句實現，該語句允許指定返回的具體記錄數。以下代碼示例展示如何獲取前 3 條記錄：

執行後，輸出結果應為前 3 條記錄。

OFFSET 關鍵字用於指定起始位置，從而獲取特定范圍內的記錄。以下代碼示例展示如何從第二條記錄開始獲取前 3 條記錄：

執行後，輸出結果應為從第二條記錄開始的前 3 條記錄。

刪除記錄時，使用 DELETE FROM 語句，確保使用 WHERE 條件語句來指定要刪除的記錄，避免誤刪整個表。以下代碼示例展示如何刪除 name 為 'stackoverflow' 的記錄：

執行後，輸出結果應為刪除的記錄數量。

為了防止 SQL 注入攻擊，使用 %s 佔位符轉義刪除條件。以下代碼示例展示如何安全地執行刪除操作：

執行後，輸出結果應為刪除的記錄數量。

更新表數據使用 UPDATE 語句，確保使用 WHERE 條件語句指定更新的數據行。以下代碼示例展示如何將 name 為 'Zhihu' 的記錄更新為 'ZH'：

執行後，輸出結果應為更新的記錄數量。

使用 %s 佔位符轉義更新條件，以防止 SQL 注入攻擊。以下代碼示例展示如何安全地執行更新操作：

執行後，輸出結果應為更新的記錄數量。

刪除表使用 DROP TABLE 語句，確保使用 IF EXISTS 關鍵字來判斷表是否存在，避免操作不存在的表。以下代碼示例展示如何刪除名為 sites 的表：

㈡ python連接MySQL資料庫問題 cursor( ) 、execute（）和fetc

MySQLdb.connect是python 連接MySQL資料庫的方法，在Python中 import MySQLdb即可使用，至於connect中的參數很簡單：x0dx0ahost：MySQL伺服器名x0dx0auser：資料庫使用者x0dx0apassword：用戶登錄密碼x0dx0adb：操作的資料庫名x0dx0acharset：使用的字元集(一般是gb2312)x0dx0acursor = db.cursor() 其實就是用來獲得python執行Mysql命令的方法,也就是x0dx0a我們所說的操作游標x0dx0a下面cursor.execute則是真正執行MySQL語句，即查詢TABLE_PARAMS表的數據。x0dx0a至於fetchall()則是接收全部的返回結果行 row就是在python中定義的一個變數，用來接收返回結果行的每行數據。同樣後面的r也是一個變數，用來接收row中的每個字元，如果寫成C的形式就更好理解了x0dx0afor(string row = '' row<= cursor.fetchall(): row++)x0dx0a for(char r = '' r<= row; r++)x0dx0aprintf("%c", r);x0dx0a大致就是這么個意思！

㈢ Python連接mysql資料庫及python使用mysqldb連接資料庫教程

做python的時候需要用到資料庫，於是自己重新整理了一下資料庫的知識，並且熟悉了python中MysqlDB模塊的功能和函數等介面，現在系統地來總結一下吧：

首先你要做的還是下載相應的模塊並且安裝啦，下載地址自己搜，網上有很多，安裝的話也很好辦，安裝之後python的安裝目錄下的Lib文件夾下的site-packages文件夾下的MySQLdb文件夾，這之中存放的便是該模塊的定義。准備工作做好之後我們需要在源碼中import MySQLdb

資料庫的連接：

模塊引入之後我們就需要和資料庫進行連接了，實例代碼如下：

db = MySQLdb.connect("localhost","root","123456","myciti" )

這三個關鍵參數的含義一目瞭然：第一個為伺服器的地址，第二個為用戶名，第三個為dbms密碼，第四個為要訪問的資料庫，其實該connect函數的參數不止這些，不過由於其有默認值而且大多數情況下不用修改，因而省略了。這里做如下列表：

host，連接的資料庫伺服器主機名，默認為本地主機(localhost)。

user，連接資料庫的用戶名，默認為當前用戶。

passwd，連接密碼，沒有默認值。

db，連接的資料庫名，沒有默認值。

conv，將文字映射到Python類型的字典。默認為MySQLdb.converters.conversions

cursorclass，cursor()使用的種類，默認值為MySQLdb.cursors.Cursor。

compress，啟用協議壓縮功能。

named_pipe，在windows中，與一個命名管道相連接。

init_command，一旦連接建立，就為資料庫伺服器指定一條語句來運行。

read_default_file，使用指定的MySQL配置文件。

read_default_group，讀取的默認組。

unix_socket，在unix中，連接使用的套接字，默認使用TCP。

port，指定資料庫伺服器的連接埠，默認是3306

大家可能會注意到源碼中沒有用到埠號，這是因為MySQLdb的connect函數的該參數的默認值便是3306，如果你在安裝mysql的時候修改了資料庫的埠號，那麼你就需要在源碼中加上該參數的修改值了。

一，安裝mysql

如果是windows 用戶，mysql 的安裝非常簡單，直接下載安裝文件，雙擊安裝文件一步一步進行操作即可。

linux 下的安裝可能會更加簡單，除了下載安裝包進行安裝外，一般的linux 倉庫中都會有mysql ，我們只需要通過一個命令就可以下載安裝：

Ubuntudeepin

>>sudo apt-get install mysql-server

>>Sudo apt-get install mysql-client

centOS/redhat

>>yum install mysql

二，安裝MySQL-python

要想使python可以操作mysql 就需要MySQL-python驅動，它是python 操作mysql必不可少的模塊。

下載地址：https://pypi.python.org/pypi/MySQL-python/

下載MySQL-python-1.2.5.zip 文件之後直接解壓。進入MySQL-python-1.2.5目錄:

>>python setup.py install

三，測試

測試非常簡單，檢查MySQLdb 模塊是否可以正常導入。

fnngj@fnngj-H24X:~/pyse$ python

Python 2.7.4 (default, Sep 26 2013, 03:20:56)

[GCC 4.7.3] on linux2

Type "help", "right", "credits" or "license" for more information.

>>> import MySQLdb

沒有報錯提示MySQLdb模塊找不到，說明安裝OK ，下面開始使用python 操作資料庫之前，我們有必要來回顧一下mysql的基本操作：

四，mysql 的基本操作

$ mysql -u root -p （有密碼時）

$ mysql -u root （無密碼時）

mysql> show databases; // 查看當前所有的資料庫

+--------------------+

| Database |

+--------------------+

| information_schema |

| csvt |

| csvt04 |

| mysql |

| performance_schema |

| test |

+--------------------+

6 rows in set (0.18 sec)

mysql> use test; //作用與test資料庫

Database changed

mysql> show tables; //查看test庫下面的表

Empty set (0.00 sec)

//創建user表，name 和password 兩個欄位

mysql> CREATE TABLE user (name VARCHAR(20),password VARCHAR(20)); Query OK, 0 rows affected (0.27 sec)

//向user表內插入若干條數據

mysql> insert into user values('Tom',񟢙');Query OK, 1 row affected (0.05 sec)

mysql> insert into user values('Alen',񡈳');Query OK, 1 row affected (0.08 sec)

mysql> insert into user values('Jack',񡂏');Query OK, 1 row affected (0.04 sec)

//查看user表的數據

mysql> select * from user;+------+----------+

| name | password |

+------+----------+

| Tom | 1321 |

| Alen | 7875 |

| Jack | 7455 |

+------+----------+

3 rows in set (0.01 sec)

//刪除name 等於Jack的數據

mysql> delete from user where name = 'Jack'Query OK, 1 rows affected (0.06 sec)

//修改name等於Alen 的password 為 1111

mysql> update user set password=񟟇' where name = 'Alen'Query OK, 1 row affected (0.05 sec)

Rows matched: 1 Changed: 1 Warnings: 0

//查看錶內容

mysql> select * from user;+--------+----------+

| name | password |

+--------+----------+

| Tom | 1321 |

| Alen | 1111 |

+--------+----------+

3 rows in set (0.00 sec)

五，python 操作mysql資料庫基礎

#coding=utf-8import MySQLdb

conn= MySQLdb.connect(

host='localhost',

port = 3306,

user='root',

passwd=�',

db ='test',

)

cur = conn.cursor()#創建數據表#cur.execute("create table student(id int ,name varchar(20),class varchar(30),age varchar(10))")#插入一條數據#cur.execute("insert into student values(ƈ','Tom',Ɖ year 2 class',Ə')")#修改查詢條件的數據#cur.execute("update student set class=Ɖ year 1 class' where name = 'Tom'")#刪除查詢條件的數據#cur.execute("delete from student where age=Ə'")cur.close()

conn.commit()

conn.close()

>>> conn = MySQLdb.connect(host='localhost',port = 3306,user='root', passwd=�',db ='test',)

Connect() 方法用於創建資料庫的連接，裡面可以指定參數：用戶名，密碼，主機等信息。

這只是連接到了資料庫，要想操作資料庫需要創建游標。

>>> cur = conn.cursor()

通過獲取到的資料庫連接conn下的cursor()方法來創建游標。

>>> cur.execute("create table student(id int ,name varchar(20),class varchar(30),age varchar(10))")

通過游標cur 操作execute()方法可以寫入純sql語句。通過execute()方法中寫如sql語句來對數據進行操作。

>>>cur.close()

cur.close() 關閉游標

>>>conn.commit()

conn.commit()方法在提交事物，在向資料庫插入一條數據時必須要有這個方法，否則數據不會被真正的插入。

>>>conn.close()

Conn.close()關閉資料庫連接

六，插入數據

通過上面execute()方法中寫入純的sql語句來插入數據並不方便。如：

>>>cur.execute("insert into student values(ƈ','Tom',Ɖ year 2 class',Ə')")

我要想插入新的數據，必須要對這條語句中的值做修改。我們可以做如下修改：

#coding=utf-8import MySQLdb

conn= MySQLdb.connect(

host='localhost',

port = 3306,

user='root',

passwd=�',

db ='test',

)

cur = conn.cursor()#插入一條數據sqli="insert into student values(%s,%s,%s,%s)"cur.execute(sqli,(Ɖ','Huhu',ƈ year 1 class',ƍ'))

cur.close()

conn.commit()

conn.close()

假如要一次向數據表中插入多條值呢？

#coding=utf-8import MySQLdb

conn= MySQLdb.connect(

host='localhost',

port = 3306,

user='root',

passwd=�',

db ='test',

)

cur = conn.cursor()#一次插入多條記錄sqli="insert into student values(%s,%s,%s,%s)"cur.executemany(sqli,[

(Ɖ','Tom',Ƈ year 1 class',ƌ'),

(Ɖ','Jack',ƈ year 1 class',ƍ'),

(Ɖ','Yaheng',ƈ year 2 class',ƍ'),

])

cur.close()

conn.commit()

conn.close()

executemany()方法可以一次插入多條值，執行單挑sql語句,但是重復執行參數列表裡的參數,返回值為受影響的行數。

七，查詢數據

也許你已經嘗試了在python中通過

>>>cur.execute("select * from student")

來查詢數據表中的數據，但它並沒有把表中的數據列印出來，有些失望。

來看看這條語句獲得的是什麼

>>>aa=cur.execute("select * from student")

>>>print aa

5

它獲得的只是我們的表中有多少條數據。那怎樣才能獲得表中的數據呢？進入python shell

>>> import MySQLdb>>> conn = MySQLdb.connect(host='localhost',port = 3306,user='root', passwd=�',db ='test',)>>> cur = conn.cursor()>>> cur.execute("select * from student")5L

>>> cur.fetchone()

(1L, 'Alen', Ƈ year 2 class', ƌ')>>> cur.fetchone()

(3L, 'Huhu', ƈ year 1 class', ƍ')>>> cur.fetchone()

(3L, 'Tom', Ƈ year 1 class', ƌ')

...>>>cur.scroll(0,'absolute')

fetchone()方法可以幫助我們獲得表中的數據，可是每次執行cur.fetchone() 獲得的數據都不一樣，換句話說我沒執行一次，游標會從表中的第一條數據移動到下一條數據的位置，所以，我再次執行的時候得到的是第二條數據。

scroll(0,'absolute') 方法可以將游標定位到表中的第一條數據。

還是沒解決我們想要的結果，如何獲得表中的多條數據並列印出來呢？

#coding=utf-8import MySQLdb

conn= MySQLdb.connect(

host='localhost',

port = 3306,

user='root',

passwd=�',

db ='test',

)

cur = conn.cursor()#獲得表中有多少條數據aa=cur.execute("select * from student")print aa#列印表中的多少數據info = cur.fetchmany(aa)for ii in info: print ii

cur.close()

conn.commit()

conn.close()

通過之前的print aa 我們知道當前的表中有5條數據，fetchmany()方法可以獲得多條數據，但需要指定數據的條數，通過一個for循環就可以把多條數據列印出啦！執行結果如下：

5(1L, 'Alen', Ƈ year 2 class', ƌ')

(3L, 'Huhu', ƈ year 1 class', ƍ')

(3L, 'Tom', Ƈ year 1 class', ƌ')

(3L, 'Jack', ƈ year 1 class', ƍ')

(3L, 'Yaheng', ƈ year 2 class', ƍ')

[Finished in 0.1s]