包含python讓mysql執行命令的詞條

本文目錄一覽：

• 1、python怎麼操作mysql
• 2、python調用mysql命令行執行sql語句的問題
• 3、如何使用Python3.4連接MySQL
• 4、python讀取mysql數據寫入ES總結
• 5、如何使python 連接mysql數據庫
• 6、如何使用python連接mysql數據庫

python怎麼操作mysql

我採用的是MySQLdb操作的MYSQL數據庫。先來一個簡單的例子吧：

import MySQLdb

try:

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

cur=conn.cursor()

cur.execute(‘select * from user’)

cur.close()

conn.close()

except MySQLdb.Error,e:

print “Mysql Error %d: %s” % (e.args[0], e.args[1])

請注意修改你的數據庫，主機名，用戶名，密碼。

下面來大致演示一下插入數據，批量插入數據，更新數據的例子吧：

import MySQLdb

try:

conn=MySQLdb.connect(host=’localhost’,user=’root’,passwd=’root’,port=3306)

cur=conn.cursor()

cur.execute(‘create database if not exists python’)

conn.select_db(‘python’)

cur.execute(‘create table test(id int,info varchar(20))’)

value=[1,’hi rollen’]

cur.execute(‘insert into test values(%s,%s)’,value)

values=[]

for i in range(20):

values.append((i,’hi rollen’+str(i)))

cur.executemany(‘insert into test values(%s,%s)’,values)

cur.execute(‘update test set info=”I am rollen” where id=3’)

conn.commit()

cur.close()

conn.close()

except MySQLdb.Error,e:

print “Mysql Error %d: %s” % (e.args[0], e.args[1])

請注意一定要有conn.commit()這句來提交事務，要不然不能真正的插入數據。

運行之後我的MySQL數據庫的結果就不上圖了。

import MySQLdb

try:

conn=MySQLdb.connect(host=’localhost’,user=’root’,passwd=’root’,port=3306)

cur=conn.cursor()

conn.select_db(‘python’)

count=cur.execute(‘select * from test’)

print ‘there has %s rows record’ % count

result=cur.fetchone()

print result

print ‘ID: %s info %s’ % result

results=cur.fetchmany(5)

for r in results:

print r

print ‘==’*10

cur.scroll(0,mode=’absolute’)

results=cur.fetchall()

for r in results:

print r[1]

conn.commit()

cur.close()

conn.close()

except MySQLdb.Error,e:

print “Mysql Error %d: %s” % (e.args[0], e.args[1])

運行結果就不貼了，太長了。

查詢後中文會正確顯示，但在數據庫中卻是亂碼的。經過我從網上查找，發現用一個屬性有可搞定：

在Python代碼

conn = MySQLdb.Connect(host=’localhost’, user=’root’, passwd=’root’, db=’python’) 中加一個屬性：

改為：

conn = MySQLdb.Connect(host=’localhost’, user=’root’, passwd=’root’, db=’python’,charset=’utf8′)

charset是要跟你數據庫的編碼一樣，如果是數據庫是gb2312 ,則寫charset=’gb2312’。

下面貼一下常用的函數：

然後,這個連接對象也提供了對事務操作的支持,標準的方法

commit() 提交

rollback() 回滾

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條.

參考資料：

MySQLdb‘s user guide

package MySQLdb

python調用mysql命令行執行sql語句的問題

我以前遇到過

你看看

目錄名稱是不是有空格 MySQL\MySQL Server 5.0\

去掉空格

如何使用Python3.4連接MySQL

MySQLdb只支持Python2.*，還不支持3.*

可以用PyMySQL代替。安裝方法：pip install PyMySQL

然後在需要的項目中，把 __init__.py中添加兩行：

import pymysql

pymysql.install_as_MySQLdb()

就可以用 import MySQLdb了。其他的方法與MySQLdb一樣。

python讀取mysql數據寫入ES總結

準備工作： mysql庫的安裝。

python中mysql庫用的是mysql-connector，安裝執行如下命令：

第一步： 連接mysql，讀取數據。

通過執行sql語句，讀取mysql數據。

至此，獲得mysql的原始數據raw_data 。接下來對數據進行預處理，按日期進行分組聚合，然後重命名行和列名，得到dataFrame格式的數據。

第二步： 連接ES。

這步沒有太多的可解釋的地方，就是配置信息。

第三步： ES主鍵加密。

這步的目的是為了保持主鍵唯一性，防止重複寫入。用的方法是md5加密。

第四步： 寫入ES

至此，一切的準備工作都做好了，數據也有了，主鍵加密也做了，就開始寫入了。

用main方法執行以上方法：

最後查看一下ES寫的是否成功，用查詢方法

如果返回以下信息，說明ES里成功插入了數據。

另外，ES刪除索引的操作：

如何使python 連接mysql數據庫

具體步驟：

序號 描述

1 去github上下載pymysql的安裝包pymysql

2 解壓到某個盤符下

3 打開cmd窗口（win環境下），進入pymysql的根目錄下執行命令，python setup.py install

4 在程序里，導入pymysql

5 開始連接數據庫

數據庫操作的API文檔連接:

如何使用python連接mysql數據庫

在 Python 語言環境下我們這樣連接數據庫。

In [1]: from mysql import connector

In [2]: cnx = connector.connect(host=”172.16.192.100″,port=3306,user=”appuser”,password=”xxxxxx”)

但是連接數據庫的背後發生了什麼呢？

答案

當我們通過驅動程序（mysql-connector-python,pymysql）連接 MySQL 服務端的時候，就是把連接參數傳遞給驅動程序，驅動程序再根據參數會發起到 MySQL 服務端的 TCP 連接。當 TCP 連接建立之後驅動程序與服務端之間會按特定的格式和次序交換數據包，數據包的格式和發送次序由 MySQL 協議 規定。MySQL 協議：整個連接的過程中 MySQL 服務端與驅動程序之間，按如下的次序發送了這些包。

MySQL 服務端向客戶端發送一個握手包，包里記錄了 MySQL-Server 的版本，默認的授權插件，密碼鹽值（auth-data）。

2. MySQL 客戶端發出 ssl 連接請求包（如果有必要的話）。

3. MySQL 客戶端發出握手包的響應包，這個包時記錄了用戶名，密碼加密後的串，客戶端屬性，等等其它信息。

4. MySQL 服務端發出響應包，這個包里記錄了登錄是否成功，如果沒有成功也會給出錯誤信息。