linux安裝mysqldb是被
linux環境下python怎樣操作mysql資料庫呢？方法如下：
首先在Linux環境下安裝mysql-python
1、下載mysql-python
打開終端：
cd /usr/local
sudo wgethttp://nchc.dl.sourceforge.net/sourceforge/mysql-python/MySQL-python-1.2.2.tar.gz
官網地址：http://sourceforge.net/projects/mysql-python/
2、解壓
sudo tar -zxvf MySQL-python-1.2.2.tar.gz
cd MySQL-python-1.2.2
3、在安裝前需進行配置
a、修改setup_posix.py中的mysql_config.path為你mysql安裝目錄的mysql_config路徑
b、修改site.cfg中的threadsafe = False，去掉mysql_config前的注釋，並改為mysql_config = /usr/local/mysql/bin/mysql_config
c、執行命令：
export LD_LIBRARY_PATH=/usr/local/mysql/lib/mysql
sudo ln -s /usr/local/mysql/lib/mysql/libmysqlclient.so /usr/lib/libmysqlclient.so.14
sudo ldconfig (這個很重要，否則後面會報錯ImportError: libmysqlclient.so.14: cannot open shared object file)
4、編譯安裝
1）python setup.py build
若未成功的話，需手動安裝setuptools：
sudo apt-get install python-setuptools
2）sudo python setup.py install
5、測試
python
>>> import MySQLdb
沒有錯誤，則表示安裝成功了。
使用python操作MySQL
使用python連接MySQL，創建資料庫，創建表格，插入/查詢數據。python_mysql.py代碼如下：
若出現類似於此的警告：
/usr/local/lib/python2.6/dist-packages/MySQL_python-1.2.2-py2.6-linux-i686.egg/MySQLdb/__init__.py:34: DeprecationWarning: the sets mole is deprecated from sets import ImmutableSet
解決辦法如下：
找到上面路徑MySQLdb下的__init__.py文件
1) 在文件中 "__init__.py"中， 注釋掉:
from sets import ImmutableSet
class DBAPISet(ImmutableSet):
新增:
class DBAPISet(frozenset):
2) 在文件"converters.py"中，注釋掉 from sets import BaseSet, Set 這一句話。
3) 在文件"converters.py"中， 修改 其中的"Set" 成為 "set" ( 只有兩個地方需要修改，即大寫改小寫)
大概 line 45: return Set([ i for i in s.split(',') if i ]) 改為 return set([ i for i in s.split(',') if i ])
大概 line 129: Set: Set2Str, 改為 set: Set2Str,
1.引入MySQLdb庫
import MySQLdb
2.和資料庫建立連接
conn=MySQLdb.connect(host="localhost",user="root",passwd="sa",db="mytable",charset="utf8")
提供的connect方法用來和資料庫建立連接,接收數個參數,返回連接對象.
比較常用的參數包括
host:資料庫主機名.默認是用本地主機.
user:資料庫登陸名.默認是當前用戶.
passwd:資料庫登陸的秘密.默認為空.
db:要使用的資料庫名.沒有默認值.
port:MySQL服務使用的TCP埠.默認是3306.
charset:資料庫編碼.
然後,這個連接對象也提供了對事務操作的支持,標準的方法
commit() 提交
rollback() 回滾
3.執行sql語句和接收返回值
cursor=conn.cursor()
n=cursor.execute(sql,param)
首先,我們用使用連接對象獲得一個cursor對象,接下來,我們會使用cursor提供的方法來進行工作.這些方法包括兩大類:1.執行命令,2.接收返回值
cursor用來執行命令的方法:
callproc(self, procname, args):用來執行存儲過程,接收的參數為存儲過程名和參數列表,返回值為受影響的行數
execute(self, query, args):執行單條sql語句,接收的參數為sql語句本身和使用的參數列表,返回值為受影響的行數
executemany(self, query, args):執行單條sql語句,但是重復執行參數列表裡的參數,返回值為受影響的行數
nextset(self):移動到下一個結果集
cursor用來接收返回值的方法:
fetchall(self):接收全部的返回結果行.
fetchmany(self, size=None):接收size條返回結果行.如果size的值大於返回的結果行的數量,則會返回cursor.arraysize條數據.
fetchone(self):返回一條結果行.
scroll(self, value, mode='relative'):移動指針到某一行.如果mode='relative',則表示從當前所在行移動value條,如果mode='absolute',則表示從結果集的第一行移動value條.
下面的代碼是一個完整的例子.
#使用sql語句,這里要接收的參數都用%s佔位符.要注意的是,無論你要插入的數據是什麼類型,佔位符永遠都要用%s
sql="insert into cdinfo values(%s,%s,%s,%s,%s)"
#param應該為tuple或者list
param=(title,singer,imgurl,url,alpha)
#執行,如果成功,n的值為1
n=cursor.execute(sql,param)
#再來執行一個查詢的操作
cursor.execute("select * from cdinfo")
#我們使用了fetchall這個方法.這樣,cds里保存的將會是查詢返回的全部結果.每條結果都是一個tuple類型的數據,這些tuple組成了一個tuple
cds=cursor.fetchall()
#因為是tuple,所以可以這樣使用結果集
print cds[0][3]
#或者直接顯示出來,看看結果集的真實樣子
print cds
#如果需要批量的插入數據,就這樣做
sql="insert into cdinfo values(0,%s,%s,%s,%s,%s)"
#每個值的集合為一個tuple,整個參數集組成一個tuple,或者list
param=((title,singer,imgurl,url,alpha),(title2,singer2,imgurl2,url2,alpha2))
#使用executemany方法來批量的插入數據.這真是一個很酷的方法!
n=cursor.executemany(sql,param)
4.關閉資料庫連接
需要分別的關閉指針對象和連接對象.他們有名字相同的方法
cursor.close()
conn.close()
以上方法就可以了。
另外，附MySQLdb的相關資料
更多關於MySQLdb的信息可以查這里：http://mysql-python.sourceforge.net/MySQLdb.html
② 在linux下 如何使用mysqlmp進行mysql的完全備份 要完整命令 記得是完全備份不是某個庫。。
mysqlmp命令
mysql資料庫導出要用到MySQL的mysqlmp工具，基本用法是：
shell> mysqlmp [OPTIONS] database [tables]
如果你不給定任何錶，整個資料庫將被導出。
通過執行mysqlmp --help，你能得到你液碼mysqlmp的版本支持的選項表。
注意，如果你運行mysqlmp沒有--quick或--opt選項，mysqlmp將在導出結果前裝載整個結果集到內存中，如果你正在導出一個大的資料庫，這將可能是一個問題。
1.1、mysqlmp支持下列選項：
--add-locks
在每個表導出之前增加LOCK TABLES並且之後UNLOCK TABLE。(為了使得更快地插入到MySQL)。
--add-drop-table
在每個create語句之慧困前增加一個drop table。
--allow-keywords
允許創建是關鍵詞的列名字。這由表名前綴於每個列名做到。
-c, --complete-insert
使用完整的insert語句(用列名字)。
-C, --compress
如果客戶和伺服器均支持壓縮，壓縮兩者間所有的信息。
--delayed
用INSERT DELAYED命令插入行。
-e, --extended-insert
使用全新多行INSERT語法。（給出更緊縮並且更快的插入語句）
-#, --debug[=option_string]
跟蹤程序的使用(為了調試)。
--help
顯示一條幫助消息並且退出。
LOAD DATA INFILE
--fields-terminated-by=...
--fields-enclosed-by=...
--fields-optionally-enclosed-by=...
--fields-escaped-by=...
--fields-terminated-by=...
這些選擇與-T選擇一起使用，並且有相應的LOAD DATA INFILE子句相同的含義。
LOAD DATA INFILE語法。
-F, --flush-logs
在開始導出前，洗掉在MySQL伺服器中的日誌文件。
-f, --force,
即使我們在一個表導出期間得到一個SQL錯誤，繼續。
-h, --host=..
從命名的主機上的MySQL伺服器導出數據。預設主機是localhost。
-l, --lock-tables.
為開始導出鎖定所有表。
-t, --no-create-info
不寫入表創建信息(CREATE TABLE語句）
-d, --no-data
不寫入表的任何行信息。如果你只想得到一個表的結構的導出，這是很有用的！
--opt
同--quick --add-drop-table --add-locks --extended-insert --lock-tables。
應該給你為讀入一個MySQL伺服器的盡可能最快的導出。
-pyour_pass, --password[=your_pass]
與伺服器連接時使用的口令。如果你不指定「=your_pass」部分，mysqlmp需要來自終端的口令。
-P port_num, --port=port_num
與一台主機連接時使用的TCP/IP埠號。（這用於連接到localhost以前埋念外的主機，因為它使用 Unix套接字。）
-q, --quick
不緩沖查詢，直接導出至stdout；使用mysql_use_result()做它。
-S /path/to/socket, --socket=/path/to/socket
與localhost連接時（它是預設主機)使用的套接字文件。
-T, --tab=path-to-some-directory
對於每個給定的表，創建一個 table_name.sql文件，它包含SQL CREATE 命令，和一個table_name.txt文件，它包含數據。 注意：這只有在mysqlmp運行在mysqld守護進程運行的同一台機器上的時候才工作。.txt文件的格式根據--fields-xxx和 --lines--xxx選項來定。
-u user_name, --user=user_name
與伺服器連接時，MySQL使用的用戶名。預設值是你的Unix登錄名。
-O var=option, --set-variable var=option設置一個變數的值。可能的變數被列在下面。
-v, --verbose
冗長模式。列印出程序所做的更多的信息。
-V, --version
列印版本信息並且退出。
-w, --where=''''where-condition''''
只導出被選擇了的記錄；注意引號是強制的！
"--where=user=''''jimf''''" "-wuserid>1" "-wuserid<1"
1.2、最常見的mysqlmp的一個備份：
雖然mysqlmp支持的命令有很多，對於大多數人而言，我們只需要使用-opt這個命令就已經足夠了，為你的資料庫做一個完整的備份：
mysqlmp --opt database > backup-file.sql
但是它對用來自於一個資料庫的信息充實另外一個MySQL資料庫也是有用的：
mysqlmp --opt database | mysql --host=remote-host -C database
1.3、使用mysqlmp導出的文件恢復資料庫
由於mysqlmp導出的是完整的SQL語句，所以用mysql客戶程序很容易就能把數據導入了：
shell> mysqladmin create target_db_name
shell> mysql target_db_name < backup-file.sql
就是
shell> mysql 庫名 < 文件名
二、使用mysqlmp定時備份資料庫的腳本
2.1、備份腳本
使用腳本每天定期執行資料庫備份操作，對每個使用mysql資料庫的人來說都很有必要，這樣的腳本網上有很多，這里摘抄一個朋友的腳本 dbbackup：
這個腳本每天最多隻執行一次，而且只保留最近五天的備份在伺服器上。
dbbackup代碼:
#!/bin/bash
#This is a ShellScript For Auto DB Backup
#Powered by aspbiz
#2004-09
#Setting
#設置資料庫名，資料庫登錄名，密碼，備份路徑，日誌路徑，數據文件位置，以及備份方式
#默認情況下備份方式是tar，還可以是mysqlmp,mysqldot
#默認情況下，用root(空)登錄mysql資料庫，備份至/root/dbxxxxx.tgz
DBName=mysql
DBUser=root
DBPasswd=
BackupPath=/root/
LogFile=/root/db.log
DBPath=/var/lib/mysql/
#BackupMethod=mysqlmp
#BackupMethod=mysqlhot
#BackupMethod=tar
#Setting End
NewFile="$BackupPath"db$(date +%y%m%d).tgz
DumpFile="$BackupPath"db$(date +%y%m%d)
OldFile="$BackupPath"db$(date +%y%m%d --date=''''5 days ago'''').tgz
echo "-------------------------------------------" >> $LogFile
echo $(date +"%y-%m-%d %H:%M:%S") >> $LogFile
echo "--------------------------" >> $LogFile
#Delete Old File
if [ -f $OldFile ]
then
rm -f $OldFile >> $LogFile 2>&1
echo "[$OldFile]Delete Old File Success!" >> $LogFile
else
echo "[$OldFile]No Old Backup File!" >> $LogFile
fi
if [ -f $NewFile ]
then
echo "[$NewFile]The Backup File is exists,Can''''t Backup!" >> $LogFile
else
case $BackupMethod in
mysqlmp)
if [ -z $DBPasswd ]
then
mysqlmp -u $DBUser --opt $DBName > $DumpFile
else
mysqlmp -u $DBUser -p$DBPasswd --opt $DBName > $DumpFile
fi
tar czvf $NewFile $DumpFile >> $LogFile 2>&1
echo "[$NewFile]Backup Success!" >> $LogFile
rm -rf $DumpFile
;;
mysqlhot)
rm -rf $DumpFile
mkdir $DumpFile
if [ -z $DBPasswd ]
then
mysqlhot -u $DBUser $DBName $DumpFile >> $LogFile 2>&1
else
mysqlhot -u $DBUser -p $DBPasswd $DBName $DumpFile >>$LogFile 2>&1
fi
tar czvf $NewFile $DumpFile >> $LogFile 2>&1
echo "[$NewFile]Backup Success!" >> $LogFile
rm -rf $DumpFile
;;
*)
/etc/init.d/mysqld stop >/dev/null 2>&1
tar czvf $NewFile $DBPath$DBName >> $LogFile 2>&1
/etc/init.d/mysqld start >/dev/null 2>&1
echo "[$NewFile]Backup Success!" >> $LogFile
;;
esac
fi
echo "-------------------------------------------" >> $LogFile
2.2、放入crontab定期執行dbbackup
假定dbbackup在/root目錄下。我們通過使用crontab命令，設置每天0點10分執行/root/dbbakup腳本。
1、 使用 crontab –e編輯crontab
2、 在crontab中加入：
#back for jabber database
10 0 * * * /root/dbbackup
③ 怎麼安裝python模塊，如何安裝python模塊，常用安裝方式
.
直接
下載的模塊文件中已經有了模塊的文件，有些模塊只有一個文件，比如較早版本的BeautifulSoup，有些是一個文件夾，比如新版本BeautifulSoup就是一個叫做bs4的文件夾。
把這些文件直接到你的python路徑下的/Lib/site-packages文件夾中，比如C:/Python27/Lib/site-packages。之後就可以在程序里直接引用了：
import BeautifulSoup
或者
from bs4 import BeautifulSoup
這是根據你放置的文件位置不同而決定的。
網上有人說直接放在Lib文件夾中就可以了。的確這樣也行，但Lib文件夾中都是自帶的模塊，看一下就會發現我們用過的random、re等模塊的代碼文件。而外部模塊一般放在site-packages文件夾中。
2.
setup.py
很多模塊里都附帶了setup.py文件，有同學直接雙擊了，然後發現沒有用。
它的使用方法是從命令行去到setup.py所在的路徑下，運行
python setup.py install
仔細看一下安裝時輸出的信息可以發現，在線學習這個命令做的事情其實也就是幫你把模塊的代碼到site-packages文件夾。
3.
setuptools
使用setuptools可以直接根據模塊名稱來自動下載安裝，不需要自己再去尋找模塊的安裝文件。不過在使用之前，你得先安裝setuptools自身。
windows平台的32位python，可以直接下載setuptools的exe文件安裝。（去搜索setuptools windows可以找到，我也上傳了一份在論壇本帖後面）
Linux用戶可以從包管理器中安裝，比如ubuntu：
apt-get install python-setuptools
windows平台64位python得用ez_setup.py進行安裝（文件我也上傳了）。這種方式也適用於所有平台。
在ez_setup.py所在文件夾下運行：
python ez_setup.py
setuptools會被安裝在python路徑\Scripts下。之後，你可以把這個路徑添加到環境變數path中，也可以直接從命令行進入到Scripts文件夾下，執行easy_install，看看是否安裝成功了。
之後，你就可以直接用它來安裝你想要的模塊，比如PIL：
easy_install PIL
視頻教程程序就會幫你自動下載安裝到site-packages里。
最後，介紹幾個不錯的模塊，供大家參考使用。
PIL - 圖形處理
PyXML - 解析和處理XML文件
MySQLdb - 連接MySQL資料庫
Tkinter - 圖形界面介面，python自帶
smtplib - 發送電子郵件
ftplib - ftp編程
PyMedia - 多媒體操作
PyOpenGL - OpenGL介面
BeautifulSoup - HTML/XML的解析器
④ 如何安裝，配置和使用Neutron的各個組件
安裝
安裝指令取決於發行版本，更具體來講，取決於您選擇的包管理實用程序。在許多情況下，必須聲明存儲庫。所以，舉例而言，如果您使用的是 Zypper，那麼您要用 zypper ar 向 libzypp 公開：
# zypper ar -f http://download.opensuse.org/repositories/Cloud:/OpenStack:/Grizzly/SLE_11_SP3/Cloud:OpenStack:Grizzly.repo
出於演示之目的，以下是 Ubuntu、Red Hat (Red Had Enterprise Linux、CentOS、Fedora）和 openSUSE 的主要命令：
Ubuntu：安裝 neutron-server 和訪問該 API 的客戶端： $sudo apt-get install neutron-server python-neutronclient
安裝插件：
$sudo apt-get install neutron-plugin-<plugin-name>
例如：
$sudo apt-get install neutron-plugin-openvswitch-agent Red Hat：類似於 Ubuntu，您必須同時安裝 Neutron 伺服器和插件 — 例如： $sudo yum install openstack-neutron$sudo yum install openstack-neutron-openvswitch openSUSE：使用以下命令： $sudo zypper install openstack-neutron$sudo zypper install openstack-neutron-openvswitch-agent
配置
大部分插件都需要一個資料庫。OpenStack Networking 的 Fedora 包包含伺服器設置實用程序腳本，負責資料庫的完整安裝和配置：
$sudo neutron-server-setup --plugin openvswitch
但也可以手動配置這些資料庫。例如，在 Ubuntu 上，您可使用以下命令安裝資料庫：
$sudo apt-get install mysql-server python-mysqldb python-sqlalchemy
如果已經為其他 OpenStack 服務安裝了一個資料庫，那麼您只需要創建一個 Neutron 資料庫：
$ mysql -u <user> -p <pass> -e "create database neutron"
必須在插件的配置文件中指定該資料庫。為此，在 /etc/neutron/plugins/plugin-name 中找到插件配置文件（例如 /etc/neutron/plugins/openvswitch/ovs_neutron_plugin.ini），然後設置連接字元串：
sql_connection = mysql://<user>:<password>@localhost/neutron?charset=utf8
使用場景
一個典型的 OpenStack Networking 設置可能很復雜，包含多達 4 個不同的物理網路。使用一個管理網路在 OpenStack 組件之間執行內部通信。一個數據網路處理實例之間的數據通信。API 網路向租戶公開了所有 OpenStack API。此外，通常需要一個外部網路來授予訪問 VM 的 Internet 的許可權。
在這些物理網路之上，可通過許多方式配置租戶需要的虛擬網路。最簡單的場景是單個平面網路。也可以有多個平面網路、每個租戶的私有網路，並提供商和每租戶路由器的組合來管理網路之間的流量。
為了了解如何在實際中使用 OpenStack Networking，我們來看一個簡單的場景，其中一個租戶創建了一個網路，定義了一個路由器來將從私有網路轉發流量，分配該網路的一個子網，並啟動一個要與該網路有關聯的實例。
以具有 Member 角色的用戶身份登錄到 OpenStack Dashboard。在導航窗格中的 Manage Network 下方，單擊 Networks，然後單擊 Create Network。
圖 1. 訪問 Networks 窗口
填入網路名稱以及第一個子網。
圖 2. 創建一個網路
提到子網，我指的是網路地址范圍（例如 10.2.0.0/16）和默認網關。
圖 3. 創建子網
也可配置 DHCP 和 DNS。
⑤ 如何在Anaconda下安裝MySQLdb，操作系統為Centos Linux，Python 2.7
操作系統為Centos Linux,由於需要在Anaconda下Python 2.7使用Mysql，操作資料庫，所以需要安裝MySQLdb命令很簡單。如圖：
系統會自動完成MySQLdb的安裝，同時更新部分包。接下來打開Sypder，盡情書寫代碼吧。
⑥ 怎麼做才能使mysql和python連接起來
什麼是 PyMySQL？
PyMySQL 是在 Python3.x 版本中用於連接 MySQL 伺服器的一個庫，Python2中則使用mysqldb。
PyMySQL 遵循 Python 資料庫 API v2.0 規范，並包含了 pure-Python MySQL 客戶端庫。
PyMySQL 安裝
在使用 PyMySQL 之前，我們需要確保 PyMySQL 已安裝。
PyMySQL 下載地址：https://github.com/PyMySQL/PyMySQL。
如果還未安裝，我們可以使用以下命令安裝最新版的 PyMySQL：
$ pip3 install PyMySQL
如果你的系統不支持 pip 命令，可以使用以下方式安裝：
1、使用 git 命令下載安裝包安裝(你也可以手動下載)：
$ git clone https://github.com/PyMySQL/PyMySQL$ cd PyMySQL/$ python3 setup.py install
2、如果需要制定版本號，可以使用 curl 命令來安裝：
$ # X.X 為 PyMySQL 的版本號$ curl -L https://github.com/PyMySQL/PyMySQL/tarball/pymysql-X.X | tar xz$ cd PyMySQL*$ python3 setup.py install
$ # 現在你可以刪除 PyMySQL* 目錄
注意：請確保您有root許可權來安裝上述模塊。
安裝的過程中可能會出現"ImportError: No mole named setuptools"的錯誤提示，意思是你沒有安裝setuptools，你可以訪問https://pypi.python.org/pypi/setuptools找到各個系統的安裝方法。
Linux 系統安裝實例：
$ wget https://bootstrap.pypa.io/ez_setup.py$ python3 ez_setup.py
資料庫連接
連接資料庫前，請先確認以下事項：
您已經創建了資料庫 TESTDB.
在TESTDB資料庫中您已經創建了表 EMPLOYEE
EMPLOYEE表欄位為 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
連接資料庫TESTDB使用的用戶名為 "testuser" ，密碼為 "test123",你可以可以自己設定或者直接使用root用戶名及其密碼，Mysql資料庫用戶授權請使用Grant命令。
在你的機子上已經安裝了 Python MySQLdb 模塊。
如果您對sql語句不熟悉，可以訪問我們的SQL基礎教程
- Database version : 5.5.20-log
- ..................................user_id = "test123"password = "password"con.execute('insert into Login values( %s, %s)' % (user_id, password))..................................
fetchone():該方法獲取下一個查詢結果集。結果集是一個對象
fetchall():接收全部的返回結果行.
rowcount:這是一個只讀屬性，並返回執行execute()方法後影響的行數。
- fname=Mac, lname=Mohan, age=20, sex=M, income=2000
原子性（atomicity）。一個事務是一個不可分割的工作單位，事務中包括的諸操作要麼都做，要麼都不做。
一致性（consistency）。事務必須是使資料庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。
隔離性（isolation）。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的，並發執行的各個事務之間不能互相干擾。
持久性（rability）。持續性也稱永久性（permanence），指一個事務一旦提交，它對資料庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。
實例：
以下實例鏈接 Mysql 的 TESTDB 資料庫：
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用 cursor() 方法創建一個游標對象 cursorcursor = db.cursor()
# 使用 execute() 方法執行 SQL 查詢 cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法獲取單條數據.data = cursor.fetchone()
print ("Database version : %s " % data)
# 關閉資料庫連接db.close()
執行以上腳本輸出結果如下：
創建資料庫表
如果資料庫連接存在我們可以使用execute()方法來為資料庫創建表，如下所示創建表EMPLOYEE：
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用 cursor() 方法創建一個游標對象 cursorcursor = db.cursor()
# 使用 execute() 方法執行 SQL，如果表存在則刪除cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
# 使用預處理語句創建表sql = """CREATE TABLE EMPLOYEE (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT )"""
cursor.execute(sql)
# 關閉資料庫連接db.close()
資料庫插入操作
以下實例使用執行 SQL INSERT 語句向表 EMPLOYEE 插入記錄：
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 插入語句sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""try: # 執行sql語句
cursor.execute(sql)
# 提交到資料庫執行
db.commit()except: # 如果發生錯誤則回滾
db.rollback()
# 關閉資料庫連接db.close()
以上例子也可以寫成如下形式：
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 插入語句sql = "INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('%s', '%s', %s, '%s', %s)" % ('Mac', 'Mohan', 20, 'M', 2000)try: # 執行sql語句
cursor.execute(sql)
# 執行sql語句
db.commit()except: # 發生錯誤時回滾
db.rollback()
# 關閉資料庫連接db.close()
以下代碼使用變數向SQL語句中傳遞參數:
資料庫查詢操作
Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。
實例：
查詢EMPLOYEE表中salary（工資）欄位大於1000的所有數據：
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 查詢語句sql = "SELECT * FROM EMPLOYEE
WHERE INCOME > %s" % (1000)try: # 執行SQL語句
cursor.execute(sql)
# 獲取所有記錄列表
results = cursor.fetchall()
for row in results: fname = row[0]
lname = row[1]
age = row[2]
sex = row[3]
income = row[4]
# 列印結果
print ("fname=%s,lname=%s,age=%s,sex=%s,income=%s" % (fname, lname, age, sex, income ))except: print ("Error: unable to fetch data")
# 關閉資料庫連接db.close()
以上腳本執行結果如下：
資料庫更新操作
更新操作用於更新數據表的的數據，以下實例將 TESTDB 表中 SEX 為 'M' 的 AGE 欄位遞增 1：
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 更新語句sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')try: # 執行SQL語句
cursor.execute(sql)
# 提交到資料庫執行
db.commit()except: # 發生錯誤時回滾
db.rollback()
# 關閉資料庫連接db.close()
刪除操作
刪除操作用於刪除數據表中的數據，以下實例演示了刪除數據表 EMPLOYEE 中 AGE 大於 20 的所有數據：
實例(Python 3.0+)
#!/usr/bin/python3
import pymysql
# 打開資料庫連接db = pymysql.connect("localhost","testuser","test123","TESTDB" )
# 使用cursor()方法獲取操作游標 cursor = db.cursor()
# SQL 刪除語句sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)try: # 執行SQL語句
cursor.execute(sql)
# 提交修改
db.commit()except: # 發生錯誤時回滾
db.rollback()
# 關閉連接db.close()
執行事務
事務機制可以確保數據一致性。
事務應該具有4個屬性：原子性、一致性、隔離性、持久性。這四個屬性通常稱為ACID特性。
Python DB API 2.0 的事務提供了兩個方法 commit 或 rollback。
實例
實例(Python 3.0+)
# SQL刪除記錄語句sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)try: # 執行SQL語句
cursor.execute(sql)
# 向資料庫提交
db.commit()except: # 發生錯誤時回滾
db.rollback()
對於支持事務的資料庫， 在Python資料庫編程中，當游標建立之時，就自動開始了一個隱形的資料庫事務。
commit()方法游標的所有更新操作，rollback（）方法回滾當前游標的所有操作。每一個方法都開始了一個新的事務。
錯誤處理
DB API中定義了一些資料庫操作的錯誤及異常，下表列出了這些錯誤和異常:
異常
描述
Warning 當有嚴重警告時觸發，例如插入數據是被截斷等等。必須是 StandardError 的子類。
Error 警告以外所有其他錯誤類。必須是 StandardError 的子類。
InterfaceError 當有資料庫介面模塊本身的錯誤（而不是資料庫的錯誤）發生時觸發。 必須是Error的子類。
DatabaseError 和資料庫有關的錯誤發生時觸發。 必須是Error的子類。
DataError 當有數據處理時的錯誤發生時觸發，例如：除零錯誤，數據超范圍等等。 必須是DatabaseError的子類。
OperationalError 指非用戶控制的，而是操作資料庫時發生的錯誤。例如：連接意外斷開、 資料庫名未找到、事務處理失敗、內存分配錯誤等等操作資料庫是發生的錯誤。 必須是DatabaseError的子類。
IntegrityError 完整性相關的錯誤，例如外鍵檢查失敗等。必須是DatabaseError子類。
InternalError 資料庫的內部錯誤，例如游標（cursor）失效了、事務同步失敗等等。 必須是DatabaseError子類。
ProgrammingError 程序錯誤，例如數據表（table）沒找到或已存在、SQL語句語法錯誤、 參數數量錯誤等等。必須是DatabaseError的子類。
NotSupportedError 不支持錯誤，指使用了資料庫不支持的函數或API等。例如在連接對象上 使用.rollback()函數，然而資料庫並不支持事務或者事務已關閉。 必須是DatabaseError的子類。