二十二、python mysql-connector的安裝和使用

Python和sql整合

安裝mysql：

安裝navcate-for-mysql視覺化操作工具：

開發包：

mysql-connector：

http://dev.mysql.com/downloads/connector/python

MYSQLdb：

https://pypi.python.org/pypi/MySQL-python

SQLAlchemy：

http://www.sqlalchemy.org

windows中安裝mysql-connector

windows中安裝mysql-connector-python-2.1.6-py2.7-winx64.msi

操作4步驟：

建立連線

獲取遊標

執行sql

關閉連線

-------------------------------------------------------

#from mysql import connector  #也可以

import mysql.connector

#Python連線資料庫的方式有好幾個模組可以提供，包括pymysql,MySQLdb,和MySQL官網的mysql-connector-python

#獲取連線conn

conn = mysql.connector.connect(host='192.168.216.7',port=3306,user='root',password='root',database='test',charset='utf8')

conn.autocommit=True #可以獲取連線後設置為自動提交

#獲取一個cursor

cursor = conn.cursor()

#1、建立表

sql_create = 'CREATE TABLE `user` ( \

  `id` int(11) NOT NULL AUTO_INCREMENT, \

  `name` varchar(20) DEFAULT NULL, \

  `age` int(1) DEFAULT NULL, \

  PRIMARY KEY (`id`) \

) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8 \

'

#提交表建立

#cursor.execute(sql_create)

########################################編寫插入sql語句

#a、直接字串插入方式

#ssqltext = 'insert into user(id,name,age) VALUES(3,"你好 ",20)'

sql_insert1 = 'insert into user(name,age) VALUES("你好 ",20)' #id為遞增，不用寫都可以

#使用cursor執行sql語句

#cursor.execute(sql_insert1)

#b、元組方式插入

sql_insert2 = 'insert into user(name,age) VALUES(%s,%s) '  #%s不是格式化符，而是佔位符。所以age也是%s

data = ('你好tuple',18)

#cursor.execute(sql_insert2, data)

#c、使用字典方式插入

sql_insert3 = 'insert into user(name,age) VALUES(%(name)s,%(age)s) '  #%()s : 中的欄位與字典中賦值欄位相同

data1 = {'name':"你好dict",'age':16}

#cursor.execute(sql_insert3, data1)

##############################################支援多次插入 使用

sql_insert4 = 'insert into user(name,age) VALUES(%s,%s) '  #%s不是格式化符，而是佔位符。所以age也是%s

data2 = [('你好tuple',18),('你t',16),('好uple',12)]

#cursor.executemany(sql_insert4,data2)

#引入faker包的Factory模組 來生成偽資料

#安裝 pip install fake-factory(老版本) 或者 pip install fake

#解除安裝 pip uninstall fake-factory 或者 pip uninstall fake ,重報錯資訊可知道，需要重新安裝Faker

# ImportError: The ``fake-factory`` package is now called ``Faker``

#from faker import factory

#userFaker = factory.Factory.create()  #pip install fake-factory包中的

#print userFaker.name()

from faker import Factory

userFaker = Factory.create()

#print userFaker.name(),userFaker.email(),userFaker.address(),userFaker.text()

sql_insert5 = 'insert into pyuser(name,email,address,content) VALUES(%s,%s,%s,%s) '

userFakerData = [(userFaker.name(),userFaker.email(),userFaker.address(),userFaker.text()) for i in range(1,20)]

#print userFakerData

#cursor.executemany(sql_insert5,userFakerData)

######################################更新資料,,嘗試批量更新？？？

sql_update = 'update user set age = 16'

#cursor.execute(sql_update)

#####################################查詢

sql_select = 'select id,name from user where age > %s and age < %s'

cursor.execute(sql_select, (16, 18))

for id,name in cursor:

    print '%s age is older than 18,and her/his id is %d'%(name, id)

##################################刪除  嘗試刪除多個？？？

sql_delete ='delete from user where age=%(age)s and name=%(name)s'

deleteData = {'age': 18, 'name': u'你好tuple'}

cursor.execute(sql_delete,deleteData)

#如果資料庫為innerdb型別，則需要提交(如果沒有設定自動提交)

#conn.commit()

#關閉cursor和conn

cursor.close()

conn.close()