當前位置:首頁 » 編程語言 » sql操作python
擴展閱讀
webinf下怎麼引入js 2023-08-31 21:54:13
堡壘機怎麼打開web 2023-08-31 21:54:11

sql操作python

發布時間: 2023-04-26 20:36:22

① python 如何使用源生sql語句查詢多個參數的情況

#coding:utf-8
#anexample
"""
--theSQLServerstorageprocess:
dropprocereproc_getconflist
go
createprocereproc_getconflist
@customerchar(6)
,@servicekeyvarchar(16)=NULL
,@dt_bgndatetime=NULL
,@dt_enddatetime=NULL
asbegin
selectbillsumidxasidx
fromconf_billsum
where1=1
andsumtypeid=1
andisnull(@customer,customercode)=customercode
andisnull(@servicekey,servicekey)=servicekey
andisnull(@dt_bgn,begintime)<endtime
andbegintime<isnull(@dt_end,endtime)
end
go

"""

importpymssql

conn=pymssql.connect(
host="192.168.70.7",
user='pyquery',
password='Qpery',
database='gb201412',
)
curr=conn.cursor()
curr.execute("execproc_getconflist%s,%s,%s,%s",
('990003',None,None,None))
foridx,incurr:
printidx
curr.close()
conn.close()

② python 怎樣使外部.sql腳本執行

直接調命令行工具導入啊。 否則就麻煩 了。需要解析主要的語句,比如create table和insert。最怕碰到復雜的引號,嵌套之類的。經常搞不定啊。

代碼挺復雜的。

③ 如何用python寫sql

python可以利用pymysql模塊操作資料庫

什麼是 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基礎教程

  • 實例:

    以下實例鏈接 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()

    執行以上腳本輸出結果如下:

  • Database version : 5.5.20-log

  • 創建資料庫表

    如果資料庫連接存在我們可以使用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語句中傳遞參數:

  • ..................................user_id = "test123"password = "password"con.execute('insert into Login values( %s, %s)' % (user_id, password))..................................

  • 資料庫查詢操作

    Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。

  • fetchone():該方法獲取下一個查詢結果集。結果集是一個對象

  • fetchall():接收全部的返回結果行.

  • rowcount:這是一個只讀屬性,並返回執行execute()方法後影響的行數。

  • 實例:

    查詢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()

    以上腳本執行結果如下:

  • fname=Mac, lname=Mohan, age=20, sex=M, income=2000

  • 資料庫更新操作

    更新操作用於更新數據表的的數據,以下實例將 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特性。

  • 原子性(atomicity)。一個事務是一個不可分割的工作單位,事務中包括的諸操作要麼都做,要麼都不做。

  • 一致性(consistency)。事務必須是使資料庫從一個一致性狀態變到另一個一致性狀態。一致性與原子性是密切相關的。

  • 隔離性(isolation)。一個事務的執行不能被其他事務干擾。即一個事務內部的操作及使用的數據對並發的其他事務是隔離的,並發執行的各個事務之間不能互相干擾。

  • 持久性(rability)。持續性也稱永久性(permanence),指一個事務一旦提交,它對資料庫中數據的改變就應該是永久性的。接下來的其他操作或故障不應該對其有任何影響。

  • 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的子類。

④ 求教,python3怎麼通過SSH隧道連接mysql資料庫並執行SQL操作

python3發布以來,獲取了廣大程序員們的差評,說不穩定,又是不兼容什麼的,不過差評歸差評,python3既然已經發布,肯定是個趨勢,但在python3.4裡面,使用原來python2.7的mysqldb已經不能連接mysql資料庫了,比較令人糾結,不過我們可以使用pymysql,來完成連接mysql的重任,步驟如下:序號描述1去github上下載pymysql的安裝包pymysql2解壓到某個盤符下3打開cmd窗口(win環境下),進入pymysql的根目錄下執行命令,pythonsetup.pyinstall4在程序里,導入pymysql5開始連接資料庫資料庫操作的API文檔連接:代碼如下:__author__='qindongliang'#導入pymysql的包importpymysqltry:#獲取一個資料庫連接,注意如果是UTF-8類型的,需要制定資料庫conn=pymysql.connect(host='localhost',user='root',passwd='qin',db='person',port=3306,charset='utf8')cur=conn.cursor()#獲取一個游標cur.execute('select*fromperson')data=cur.fetchall()fordindata:#注意int類型需要使用str函數轉義print("ID:"+str(d[0])+'名字:'+d[1]+"性別:"+d[2])cur.close()#關閉游標conn.close()#釋放資料庫資源exceptException:print("發生異常")結果如下:D:\python\python.exeD:/pythonide/pythonprojectworkspace/python/mysql.pyID:1名字:秦天性別:男ID:2名字:王晶性別:女Processfinishedwithexitcode0

⑤ 【分析篇】:Pandas像sql操作python 進行數據分析

前言:Python數據分析的基礎在於對數據的提取,清洗,匯總,並思明派考整理發現數據規律的過程。以下模塊敏槐毀是個人在數據橋備分析常用模塊,特此總結,便於查閱,構建數據分析體系。

⑥ Python3連sqlsver沒反應,怎麼破,每次到連接操作就直接卡住了

以前用php連mssqy時也經常出現中文亂碼(中文變問號)的問題,那時就明白是編碼沒設置好導航,現在的Python連mssql資料庫也同樣出現這問題,問題一樣,解決的辦法當然也會相似,現在我們來看看解決方法。

python一直對中文支持的不好,最近老遇到編碼問題,而且幾乎沒有通用的方案來解決這個問題,但是對常見的方法都試過之後,發現還是可以解決的,下面總結了常用的支持中文的編碼問題(這些方法中可能其中一個就能解決問題,也可能是多個組合)。

(1)、首先,要保證文件的開頭要加上編碼設置來說明文件的編碼

代碼如下
復制代碼

#encoding=utf-8

(2)、然後,在連接數據的連接參數里加上字元集說明查詢出的結果的編碼,這個不加的後果可能是查詢出的漢字字元都是問號

代碼如下
復制代碼

conn=pymssql.connect(server='.',user='', password='',database='MyTest',charset='utf8')

(3)、設置python系統的默認編碼(對於文件來說,這招幾乎屢試不爽,呵呵~~)

代碼如下
復制代碼

import sys
reload(sys)
sys.setdefaultencoding('utf8')

注意:上述編碼是「utf8」,而不是「utf-8」,我也沒弄明白,大部分情況下,這個無所謂的,但是這里我試了必須要是「utf8」

一個簡單的完整的python連接mssqlserver的例子如下(得安裝pymssql包):

代碼如下
復制代碼

#encoding:utf8
import sys
reload(sys)
sys.setdefaultencoding('utf8')
import pymssql
try:
conn=pymssql.connect(server='.',user='', password='',database='MyTest',charset='utf8')
sql="select * from UserInfo"

cur=conn.cursor()
cur.execute(sql)
data=cur.fetchall()
conn.close()
print data
except Exception,e:
print e

運行結果如下:

代碼如下
復制代碼

[(u'20093501', u'xb9xf9xbexb8', u'u7537 ', 35, u'xb4xf3xcfxc0'),
(u'20093502', u'xbbxc6xc8xd8', u'u5973 ', 34, u'xc3xc0xc5xae'),
(u'20093503', u'xc1xeexbaxfcxb3xe5', u'u7537 ', 25, u'2Bxc7xe0xc4xea'),
(u'20093504', u'xc8xcexd3xafxd3xaf', u'u5973 ', 24, u'xc6xafxc1xc1')]
[Finished in 0.2s]

雖然擺脫了問號和亂碼的困擾,但這仍不是我們想要的結果,但這個確實是正確的,因為結果是utf8編碼。這個現象確實詭異,請教了許多高手,得知,最好的結果就是逐個欄位查詢,才能顯示中文,整個查詢的話,會以utf8的格式顯示出來。

上述代碼中第14行data是整個查詢的結果,如果指定某個具體的欄位,如print data[0][2](表示取查詢結果的第一行第三列的欄位的值),則會輸出中文。

其實不僅僅是mssqlserver資料庫,mysql(需下載MySQLdb包)、sqllite(python自帶的文件資料庫)、mongodb(需下載PyMongo包)等或者是普通文本文件也是類似的解決方案。

⑦ pythonsql語句怎麼和代碼分集

#以下是python代碼
#!/usr/bin/python3.3
import re

def main():
#先得到要分割的文件的起始和結束位置所在行數並放入列表x中
count,total,j,l = 0, 0, 0, 0
x = [0,]
fin = open('c.sql','r')
for line in fin:
total += 1
if re.search('-- -----*',line): #以此判斷表的數量
count += 1
if count % 10 == 0: #每到10張表時將分割的行數寫入x列表中
#print(count,total)
x.append(total)

x.append(len(open('c.sql').readlines())+1) #將最後一行也放入x中

for i in x:
print(i,end = ' ')

print()

cnt=1
#讀取x中的行數,起始和結束位置將文件內容復制到新文件中
for i,j in enumerate(open('c.sql','r')):
if i<=x[cnt]:
with open('%dc.sql'%cnt,'a+') as f:
f.write(j)
else:
cnt+=1
print("wirte file"+str(cnt))
print("ok")
if __name__=='__main__':main()
python分割sql文件的更多相關文章
python分割txt文件
a=open('A.txt','r').readlines() n=3 #份數 qty=len(a)//n if len(a)%n==0 else len(a)//n+1 #每一份的行數 for i ...

python代碼執行SQL文件(逐句執行)
一.簡介 關於Python如何連返槐接資料庫並執行SQL語句,幾乎所有的Python教程都會講,教程里基本只介紹了執行單條SQL語句的方法,但是實際生產過程中可不只是執行一兩條語句,動輒幾十條甚至上百條的 ...

python將json格式的數據轉換成文本格畢蘆式的數據或sql文件
python如何將json格式的數據快速的轉化成指定格式的數據呢?或者轉換成sql文件? 下面的例子是將json格式的數據准換成以#_#分割的文本數據,也可用於生成sql文件. [root@bogon ...

使用Python批量修改資料庫執行Sql文件
由於上篇文章中批量修改了文件,有的時候資料庫也需要批量修改一下,之前的做法是使用寶塔的phpMyAdmin導出一個已經修改好了的sql文件,然後依次去其他資料庫里導入,效率不說極低,也算低了,且都是些 ...

python學習——大文件分割與合並
在平漏數友常的生活中,我們會遇到下面這樣的情況: 你下載了一個比較大型的游戲(假設有10G),現在想跟你的同學一起玩,你需要把這個游戲拷貝給他. 然後現在有一個問題是文件太大(我們不考慮你有移動硬碟什麼的情 ...

用python合並N個不同字元集編碼的sql文件的實踐
背景:我有一項工作任務是將svn某文件夾日常更新的sql文件(歸類到日期命名的文件夾中)拿到資料庫中運行. 一開始,我是先把sql文件update下來,用notepad++打開,拷貝每個文本的sql語 ...

⑧ 如何python獲取sql資料庫訪問的url

python
操作資料庫,要安裝一個Python和資料庫交互的包MySQL-python-1.2.2.win32-py2.5.exe,然後我們就可以使用MySQLdb這個包進行資料庫操作了。

操作步驟如下:
1、建立資料庫連接
import
MySQLdb
conn=MySQLdb.connect(host="localhost",user="root",passwd="sa",db="mytable")
cursor=conn.cursor()
2、執行資料庫操作
n=cursor.execute(sql,param)
我們要使用連接對象獲得一個cursor對象,接下來,我們會使用cursor提供的方法來進行工作.
這些方法包括兩大類:1.執行命令,2.接收返回值

3、cursor用來執行命令的方法:

callproc(self, procname,
args):用來執行存儲過程,接收的參數為存儲過程名和參數列表,返回值為受影響的行數
execute(self, query,
args):執行單條sql語句,接收的參數為sql語句本身和使用的參數列表,返回值為受影響的行數
executemany(self, query,
args):執行單挑sql語句,但是重復執行參數列表裡的參數,返回值為受影響的行數

nextset(self):移動到下一個結果集

4、cursor用來接收返回值的方法:


fetchall(self):接收全部的返回結果行.
fetchmany(self,
size=None):接收size條返回結果行.如果size的值大於返回的結果行的數量,則會返回cursor.arraysize條數據.

fetchone(self):返回一條結果行.
scroll(self, value,
mode='relative'):移動指針到某一行.如果mode='relative',則表示從當前所在行移動value條,如果mode='absolute',則表示從結果集的第一
行移動value條.

5、下面的代碼是一個完整的例子.

#使用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)
需要注意的是(或者說是我感到奇怪的是),在執行完插入或刪除或修改操作後,需要調用一下conn.commit()方法進行提交.這樣,數據才會真正保
存在資料庫中.我不清楚是否是我的mysql設置問題,總之,今天我在一開始使用的時候,如果不用commit,那數據就不會保留在資料庫中,但是,數據
確實在資料庫呆過.因為自動編號進行了累積,而且返回的受影響的行數並不為0.

6、關閉資料庫連接

需要分別的關閉指針對象和連接對象.他們有名字相同的方法
cursor.close()
conn.close()

Django操作資料庫
django是一個出色的用於python的web框架。django連接有操作資料庫的api,使用起來十分簡潔。我們在settings.py中配置好所要連接的資料庫,然後在moles、view、urls中分別寫好業務邏輯

⑨ python如何操作SQL語句

這里有個比較清楚的解答:
http://..com/question/262503775.html
但是你的是一個文本的話,就要稍微改一下咯
如果改成cx_Oracle的話,就是這樣的:
import
sys
import
cx_Oracle
import
os
class
handleDataBase:
def
__init__(self,user,passwd,server,sql):
self.user=user
self.passwd=passwd
self.server=server
self.sql=sql
self.conn
=
cx_Oracle.connect("%s/%s@%s"%(self.user,self.passwd,self.server))
def
selectDB(self):
cursor
=
self.conn.cursor()
cursor.execute("select
count(1)
from
search_item_08")
ret
=
cursor.fetchall()
cursor.close()
print
ret
return
ret
def
closeDB(self):
self.conn.close()
if
__name__
==
"__main__":
if
len(sys.argv)
<
4:
print
"Need
Arguments:
user
passwd
server"
sys.exit(1)
user=sys.argv[1]
passwd=sys.argv[2]
server=sys.argv[3]
#sql='select
count(1)
from
search_item_08;'
#注意這里要改
sql
=
open('a.sql','r').read()
#改成從文件讀取
#接下來就訪問資料庫了
handleDB
=
handleDataBase(user,passwd,server,sql)
handleDB.selectDB()
handleDB.closeDB()

⑩ 掌握Python 操作 MySQL 資料庫

本文Python 操作 MySQL 資料庫需要是使用到 PyMySQL 驅動

Python 操作 MySQL 前提是要安裝好 MySQL 資料庫並能正常連接使用,安裝步驟詳見下文。

注意: 安裝過程我們需要通過開啟管理員許可權來安裝,否則會由於許可權不足導致無法安裝。

首先需要先下載 MySQL 安裝包, 官網下載地址 下載對應版本即可,或直接在網上拉取並安裝:

許可權設置:

初始化 MySQL:

啟動 MySQL:

查看 MySQL 運行狀態:

Mysql安裝成功後,默認的root用戶密碼為空,你可以使用以下命令來創建root用戶的密碼:

登陸:

創建資料庫:

查看資料庫:

PyMySQL 模塊使用 pip命令進行安裝:

假如系統不支持 pip 命令,可以使用以下方式安裝:

pymysql .connect 函數:連接上資料庫

輸出結果顯示如下:表面資料庫連接成功

使用 pymysql 的 connect() 方法連接資料庫,connect 參數解釋如下:

conn.cursor():獲取游標

如果要操作資料庫,光連接數據是不夠的,咱們必須拿到操作資料庫的游標,才能進行後續的操作,游標的主要作用是用來接收資料庫操作後的返回結果,比如讀取數據、添加數據。通過獲取到的資料庫連接實例 conn 下的 cursor() 方法來創建游標,實例如下:

輸出結果為:

cursor 返回一個游標實例對象,其中包含了很多操作數據的方法,如執行sql語句,sql 執行命令: execute() 和 executemany()

execute(query,args=None):


executemany(query,args=None):

其他游標對象如下表:

完整資料庫連接操作實例如下:

以上結果輸出為:

創建表代碼如下:

如下所示資料庫表創建成功:

插入數據實現代碼:

插入數據結果:

Python查詢Mysql使用 fetchone() 方法獲取單條數據, 使用fetchall() 方法獲取多條數據。

查詢數據代碼如下:

輸出結果:

DB API中定義了一些資料庫操作的錯誤及異常,下表列出了這些錯誤和異常:

本文給大家介紹 Python 如何連接 Mysql 進行數據的增刪改查操作,文章通過簡潔的代碼方式進行示例演示,給使用 Python 操作 Mysql 的工程師提供支撐。