python-05

首先是安装工具

Linux

• 安装mysql：mysql-server
• 安装python-mysql模块： python-mysqldb

Windows

• 下载安装mysql
• python操作mysql模块：MySQL-python-1.2.3.win32-py2.7.exe 或 MySQL-python-1.2.3.win-amd64-py2.7.exe
• mysql图形界面：Navicat_for_MySQL

创建数据库

create table students
    (
        id int  not null auto_increment primary key,
        name char(8) not null,
        sex char(4) not null,
        age tinyint unsigned not null,
        tel char(13) null default "-"
    );

插入一条数据： insert into student  (name,sex,age,tel) values('test','man',19,'123456777')

MySQLdb的操作：
查询

#!/usr/bin/env python
#-*- encoding: utf-8 -*-

import MySQLdb

conn = MySQLdb.connect(host='127.0.0.1', user = 'root',passwd ='123456',db='yangshanlei')  #连接mysql
cur = conn.cursor()   #创建游标

reCount = cur.execute('select * from students')   #查询sql语句
data = cur.fetchall()     #把得到的数据都拿出来
 

cur.close()   #关闭游标
conn.close()  #关闭连接

print reCount    #查询出影响行数
print data

 insert

#!/usr/bin/env python
#-*- encoding: utf-8 -*-

import MySQLdb

conn = MySQLdb.connect(host='127.0.0.1', user = 'root',passwd ='123456',db='yangshanlei')  #连接mysql
cur = conn.cursor()   #创建游标

sql = "insert into students  (name,sex,age,tel) values(%s,%s,%s,%s)"
params = ('yang','man',19,'2222222')    


reCount = cur.execute(sql,params)
conn.commit()        #insert update delete都需要加上commit

cur.close()   #关闭游标
conn.close()  #关闭连接

print reCount    #查询出影响行数

#!/usr/bin/env python
#-*- encoding: utf-8 -*-

import MySQLdb

conn = MySQLdb.connect(host='127.0.0.1', user = 'root',passwd ='123456',db='yangshanlei')  #连接mysql
cur = conn.cursor()   #创建游标
 
li =[
     ('www','usa',19,'555'),
     ('sss','usa',19,'666')
     ]

reCount = cur.executemany("insert into students (name,sex,age,tel) values(%s,%s,%s,%s)",li)  

conn.commit()        #insert update delete都需要加上commit
cur.close()   #关闭游标
conn.close()  #关闭连接

print reCount    #查询出影响行数

delete

#!/usr/bin/env python
#-*- encoding: utf-8 -*-

import MySQLdb

conn = MySQLdb.connect(host='127.0.0.1', user = 'root',passwd ='123456',db='yangshanlei')  #连接mysql
cur = conn.cursor()   #创建游标

sql = "delete from students where name =%s"
params = ('test1',)    


reCount = cur.execute(sql,params)
conn.commit()        #insert update delete都需要加上commit

cur.close()   #关闭游标
conn.close()  #关闭连接

print reCount    #查询出影响行数

update

#!/usr/bin/env python
#-*- encoding: utf-8 -*-

import MySQLdb

conn = MySQLdb.connect(host='127.0.0.1', user = 'root',passwd ='123456',db='yangshanlei')  #连接mysql
cur = conn.cursor()   #创建游标

sql = "update students set name  = %s  where id = 1"
params = ('sb',)    


reCount = cur.execute(sql,params)
conn.commit()        #insert update delete都需要加上commit

cur.close()   #关闭游标
conn.close()  #关闭连接

print reCount    #查询出影响行数

#!/usr/bin/env python
#-*- encoding: utf-8 -*-
import MySQLdb

class helperall(object):
    def __init__(self):
        pass

    def Get_Dict(self,sql,params):
        #conn = MySQLdb.connect('127.0.0.1','root','123456','yangshanlei')
        conn = MySQLdb.connect(host='127.0.0.1', user = 'root',passwd ='123456',db='yangshanlei')    
        cur = conn.cursor()

        reCount = cur.execute(sql,params)
        date = cur.fetchall()

        cur.close()
        conn.close()

        return date

    def Get_One(self,sql,params):
        conn = MySQLdb.connect('127.0.0.1','root','123456','yangshanlei')
        cur = conn.cursor() #打开游标

        reCount = cur.execute(sql,params) 
        data = cur.fetchone()

        cur.close()
        conn.close()
        return data

    def Get_insertone(self,sql,params):
        conn = MySQLdb.connect('127.0.0.1','root','123456','yangshanlei')
        cur = conn.cursor()

        reCount = cur.execute(sql,params) 
        conn.commit()

        cur.close()
        conn.close()
        return reCount

    def Get_insertall(self,sql,li):
        conn = MySQLdb.connect('127.0.0.1','root','123456','yangshanlei')
        cur = conn.cursor()      

        reCount = cur.executemany(sql,li)  

        conn.commit()        #insert update delete都需要加上commit
        cur.close()
        conn.close()

'''
#插入多次
helper = helperall()
li =[
         ('ww1','usa'),
         ('ss1','usa')
         ]
sql = "insert into students  (name,sex) values(%s,%s)"
dicct_insertall = helper.Get_insertall(sql,li)
print dicct_insertall
'''
'''
#插入一次
helper = helperall()
sql = "insert into students  (name,sex) values(%s,%s)"
params = ('yangshan','man')
dicct_insert = helper.Get_insertone(sql,params)
print dicct_insert
'''
'''
#查询
helper = helperall()
sql = "select *  from students   where id > %s"
params = (1,)
dict_data = helper.Get_Dict(sql,params)  #查询全部
dict_one = helper.Get_One(sql,params)     #查询1次
print dict_data
print dict_one  
'''