摘要：本文給大家匯總介紹了使用python連接mysql的幾個(gè)實(shí)例，非常的簡(jiǎn)單實(shí)用示例一#coding=UTF-8  import sys import MySQLdb import time  reload(sys) sys.setdefaultencoding('utf-8')  def connectDemo()

本文給大家匯總介紹了使用python連接mysql的幾個(gè)實(shí)例，非常的簡(jiǎn)單實(shí)用

示例一

#coding=UTF-8 
import sys
import MySQLdb
import time 
reload(sys)
sys.setdefaultencoding('utf-8') 
def connectDemo():
  return MySQLdb.Connection("127.0.0.1","root","root","demo",3306,charset="utf8")  
if __name__ == '__main__':
  begin=time.time() 
  conn=connectDemo()
  cursor = conn.cursor()
  sql="""
    show tables
    """
  count = cursor.execute(sql)
  rows = cursor.fetchall()
  cursor.close()
  conn.close()
  print "========demo庫(kù)共:%s 張表============" % (count) 
  print '耗時(shí):%s 秒' % (time.time()-begin)

示例二

import MySQLdb
conn = MySQLdb.connect(host="localhost",
user="root",
passwd="123456",
db="test")
cursor = conn.cursor()
cursor.execute("SELECT * from hard")
res = cursor.fetchall()
for x in res:
print x
cursor.close()
conn.close()

示例三

1 安裝Python的Mysql包

root@10.1.1.45:~# apt-get install python-mysqldb
root@10.1.1.45:~# python
Python 2.5.2 (r252:60911, Jan 4 2009, 21:59:32) 
[GCC 4.3.2] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> import MySQLdb
>>>

這里導(dǎo)入MySQLdb沒(méi)有報(bào)錯(cuò),就說(shuō)明安裝成功.

2 下面就可以連接數(shù)據(jù)庫(kù),可以進(jìn)行增刪改操作.

root@10.1.1.45:python# cat create.py 
#!/usr/bin/env python
#coding=utf-8
  
#導(dǎo)入相關(guān)模塊
import MySQLdb
  
#建立和mysql數(shù)據(jù)庫(kù)的連接
conn = MySQLdb.connect(host='localhost',user='root',passwd='davehe')
#獲取游標(biāo)
curs = conn.cursor()
#執(zhí)行SQL,創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)
curs.execute("create database pythondb")
#選擇連接哪個(gè)數(shù)據(jù)庫(kù)
conn.SELECT_db('pythondb')
#執(zhí)行SQL,創(chuàng)建一個(gè)表
curs.execute("create table test(id int,message varchar(50))")
#插入一條記錄
value = [1,"davehe"]
curs.execute("INSERT into test values(%s,%s)",value)
#插入多條記錄
values = []
for i in range(20):
  values.append((i,'hello mysqldb' + str(i)))
curs.executemany("INSERT into test values(%s,%s)",values)
#提交修改                
conn.commit()
#關(guān)閉游標(biāo)連接,釋放資源
curs.close()
#關(guān)閉連接
conn.close()
root@10.1.1.45:python# ./create.py

3 下面利用python查看mysql里剛添加的記錄.

root@10.1.1.45:python# cat SELECT.py 
#!/usr/bin/env python
#coding=utf-8
  
#導(dǎo)入相關(guān)模塊
import MySQLdb
  
#建立和mysql數(shù)據(jù)庫(kù)的連接
conn = MySQLdb.connect(host='localhost',user='root',passwd='hc1226')
#獲取游標(biāo)
curs = conn.cursor()
#選擇連接哪個(gè)數(shù)據(jù)庫(kù)
conn.SELECT_db('pythondb')
#查看共有多少條記錄
count = curs.execute('SELECT * from test')
print "一共有%s條記錄" % count
#獲取一條記錄,以一個(gè)元組返回
result = curs.fetchone()
print "當(dāng)前的一條記錄 ID:%s message:%s" % result
#獲取后10條記錄,由于之前執(zhí)行了getchone(),所以游標(biāo)已經(jīng)指到第二條記錄,下面也就從第二條記錄開(kāi)始返回
results = curs.fetchmany(10)
for r in results:
  print r
#重置游標(biāo)位置,0,為偏移量,mode = relative(默認(rèn))
curs.scroll(0,mode='absolute')
#獲取所有記錄
results = curs.fetchall()
for r in results:
  print r
  
#提交修改
conn.commit()
#關(guān)閉游標(biāo)連接,釋放資源
curs.close()
#關(guān)閉連接
conn.close()

root@10.1.1.45:python# ./SELECT.py 
一共有21條記錄
當(dāng)前的一條記錄 ID:1 message:davehe
(0L, 'hello mysqldb0')
(1L, 'hello mysqldb1')
(2L, 'hello mysqldb2')
(3L, 'hello mysqldb3')
(4L, 'hello mysqldb4')
(5L, 'hello mysqldb5')
(6L, 'hello mysqldb6')
(7L, 'hello mysqldb7')
(8L, 'hello mysqldb8')
(9L, 'hello mysqldb9')
(1L, 'davehe')
(0L, 'hello mysqldb0')
(1L, 'hello mysqldb1')
(2L, 'hello mysqldb2')
(3L, 'hello mysqldb3')
(4L, 'hello mysqldb4')
(5L, 'hello mysqldb5')
(6L, 'hello mysqldb6')
(7L, 'hello mysqldb7')
(8L, 'hello mysqldb8')
(9L, 'hello mysqldb9')
(10L, 'hello mysqldb10')
(11L, 'hello mysqldb11')
(12L, 'hello mysqldb12')
(13L, 'hello mysqldb13')
(14L, 'hello mysqldb14')
(15L, 'hello mysqldb15')
(16L, 'hello mysqldb16')
(17L, 'hello mysqldb17')
(18L, 'hello mysqldb18')
(19L, 'hello mysqldb19')

更多關(guān)于python連接mysql實(shí)例分享請(qǐng)關(guān)注PHP中文網(wǎng)（ipnx.cn）其他文章！