它实现了 Python 数据库,因为我们不可能去构造出

2019-10-05 08:28栏目:网络数据
TAG:

 


(1) 什么是MySQLdb?

安装:pip3 install pymysql

 数据库编制程序

从前方大家通晓数据库概念包蕴数据库文件、服务器和数据库顾客端 顾客端大家前边早就用过的有navicat/mysql-client等次第。

主题素材: 怎样运用顾客端将一千00行数据插入到数据库?

世家会意识只要用事先顾客端差不离是不只怕完全那么些职务的, 因为大家不大概去组织出分外插入10w行数据的SQL。可是,假使大家有四个作用能够插入一行数据,借助程序庞大的性状-重复,就能够轻松的就将10w行数据收入麾下。这种经过应用程序代码的点子去老是数据库服务器,通过和服务器进行交互达成对数据库的增加和删除改查的秘技,就称为数据库编制程序。

而那时上学的pymysql正是一种顾客端。

  MySQLdb 是用于 Python 连接 MySQL 数据库的接口,它实现了 Python 数据库 API 标准 V2.0,基于 MySQL C API 上创设的。

引进模块在python3里:from pymysql import *

 Python 中操作 MySQL 步骤

怎么着通晓连接 connection 和 游标 cursor connection就好像连接出发地和指标地的 高速公路cursor就像在高速度公路上的货车-拉货 大家利用游标就足以做到对数据的操作 当大家成功操作完成后就能够告一段落货车,然后公路再甘休使用。

(2) 源码安装 MySQLdb:

动用手续:

pymysql的使用

引进模块

from pymysql import connect

$ tar zxvf MySQL-python-*.tar.gz
$ cd MySQL-python-*
$ python setup.py build
$ python setup.py install 

Python能源分享群:484031800

Connection 对象

  • 用于建构与数据库的连接 调用pymysql模块中的connect()方法
conn=connect(参数列表)

* 参数host:连接的mysql主机,如果本机是'localhost'
* 参数port:连接的mysql主机的端口,默认是3306
* 参数database:数据库的名称
* 参数user:连接的用户名
* 参数password:连接的密码
* 参数charset:通信采用的编码方式,推荐使用utf8
  • 关闭连接 conn.close()

  • 交给数据 conn.commit()

  • 撤废数据 conn.rollback()

  • 因而连日获取游标 cur = conn.cursor()回到Cursor对象,用于实行sql语句并获取结果

(3) MySQLdb 的使用:

1、创建Connection对象,用于塑造与数据库的接连,创造对象调用connect()方法conn=connect

Cursor游标对象

  • 获取Cursor对象

      # 调用Connection对象的cursor()方法    
      cur =conn.cursor()
    

目标: 实施sql语句(使用频度最高的口舌为select、insert、update、delete)

  • 利用游标施行SQL语句

execute(operation [, parameters ]) 实施SQL语句,重临受影响的行数,首要用于施行insert、update、delete语句,也得以实践create、alter、drop等语句

  • 关闭游标 cur.close()
  • 收获结果聚集的一条

    cur.fetchone()回去三个元组 形如 (1,'苏妲己',18)

  • 获取结果集中的享有

    cur.fetchall()实施查询时,获取结果集的有所行,一行构成二个元组,再将那么些元组装入贰个元组再次来到形如((1,'公孙离',20),(2,'己妲',18))

#!/usr/bin/env python
# coding=utf-8

参数host:连接mysql的主机,假诺本机就用localhost

pymysql达成多少查询

import pymysql

# 创建和数据库服务器的连接 服务器地址   端口    用户名     密码  数据库名 通信使用字符和数据库字符集一致
conn = pymysql.connect(host='localhost', port=3306, user='root', password='mysql',database='python_test_1', charset='utf8')

# 获取游标
cursor = conn.cursor()

# 执行SQL语句 返回值就是SQL语句在执行过程中影响的行数
sql = """select * from hero;"""

row_count = cursor.execute(sql)
print("SQL语句执行影响的行数%d" % row_count)

# 取出结果集中一行  返回的结果是一行 (1, '妲己', 2)
# print(cursor.fetchone())

# 取出结果集中的所有数据  返回 ((一行数据),(),())
# ((1, '妲己', 2), (2, '李白', 1), (3, '程咬金', 3), (4, '亚瑟', 5), (5, '荆轲', 99))
for line in cursor.fetchall():
    print(line)

# 关闭游标
cursor.close()

# 关闭连接
conn.close()

import MySQLdb

参数port:连接mysql的端口,默认是3306

pymysql完毕对数据库的增加和删除改

import pymysql

conn = pymysql.connect(host='127.0.0.1',port=3306,user='root',password='mysql',db='python_test_1', charset='utf8')

# 通过连接获取游标
cursor = conn.cursor()


# sql = "delete from hero where id = 5;"
# sql = insert into hero (name) values ('西部大坏蛋孙悟空');
sql = "update hero set kongfuid=444 where id = 4;"

row_count = cursor.execute(sql)
print("SQL语句执行影响的行数%d" % row_count)

# 提交数据到数据库
# conn.commit()

# 回滚数据到什么都不做的状态 即撤销刚刚的修改
conn.rollback()

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

关于提交commit commit将修改提交到数据库,保存修改

style="font-size: 14px">注意pymysql中多少须求手动提交commit技能保留到数据库中

def connectdb():
    print('连接到mysql服务器...')
    # 张开数据库连接
    # 客商名:p, 密码:12345.,顾客名和密码须要改成你和谐的mysql顾客名和密码,并且要开创数据库TESTDB,并在TESTDB数据库中创建好表Student
    db = MySQLdb.connect("localhost","p","12345.","TESTDB")
    print('连接上了!')
    return db

参数database:数据库名称

参数化列表幸免SQL注入

怎么着是SQL注入 爆发原因: 后台将客户提交的带有恶意的数码和SQL实行字符串情势的拼凑,进而影响了SQL语句的语义,最后产生多少败露的景色。 借使幸免: sql语句的参数化, 将SQL语句的保有数据参数存在贰个列表中传递给execute函数的第二个参数

注意

* 此处不同于python的字符串格式化,必须全部使用%s占位
* 所有参数所需占位符外不需要加引号
from pymysql import connect

def main():

    find_name = input("请输入物品名称:")

    # 创建Connection连接
    conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset='utf8')
    # 获得Cursor对象
    cs1 = conn.cursor()


    # # 非安全的方式
    # # 输入 " or 1=1 or "   (双引号也要输入)
    # sql = 'select * from goods where name="%s"' % find_name
    # print("""sql===>%s<====""" % sql)
    # # 执行select语句,并返回受影响的行数:查询所有数据
    # count = cs1.execute(sql)

    # 安全的方式
    # 构造参数列表 
    params = [find_name]
    # 执行select语句,并返回受影响的行数:查询所有数据
    count = cs1.execute('select * from goods where name=%s', params)
    # 注意:
    # 如果要是有多个参数,需要进行参数化
    # 那么params = [数值1, 数值2....],此时sql语句中有多个%s即可 

    # 打印受影响的行数
    print(count)
    # 获取查询的结果
    # result = cs1.fetchone()
    result = cs1.fetchall()
    # 打印查询的结果
    print(result)
    # 关闭Cursor对象
    cs1.close()
    # 关闭Connection对象
    conn.close()

if __name__ == '__main__':
    main()

def createtable(db):
    # 使用cursor()方法得到操作游标 
    cursor = db.cursor()
    # 假如存在表Sutdent先删除
    cursor.execute("DROP TABLE IF EXISTS Student")
    sql = """CREATE TABLE Student (
            ID CHAR(10) NOT NULL,
            Name CHAR(8),
            Grade INT )"""
    # 创建Sutdent表
    cursor.execute(sql)

参数user:连接的顾客名

def insertdb(db):
    # 使用cursor()方法猎取操作游标 
    cursor = db.cursor()
    # SQL 插入语句
    sql = """INSERT INTO Student
         VALUES ('001', 'CZQ', 70),
                ('002', 'LHQ', 80),
                ('003', 'MQ', 90),
                ('004', 'WH', 80),
                ('005', 'HP', 70),
                ('006', 'YF', 66),
                ('007', 'TEST', 100)"""

参数password:连接的密码

    #sql = "INSERT INTO Student(ID, Name, Grade)
    #    VALUES ('%s', '%s', '%d')" %
    #    ('001', 'HP', 60)
    try:
        # 执行sql语句
        cursor.execute(sql)
        # 提交到数据库推行
        db.commit()
    except:
        # Rollback in case there is any error
        print '插入数据失利!'
        db.rollback()

参数charset:通讯选取的编码形式,暗许是utf-8

def querydb(db):
    # 使用cursor()方法获得操作游标 
    cursor = db.cursor()
    # SQL 查询语句
    #sql = "SELECT * FROM Student
    #    WHERE Grade > '%d'" % (80)
    sql = "SELECT * FROM Student"
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 获取具备记录列表
        results = cursor.fetchall()
        for row in results:
            ID = row[0]
            Name = row[1]
            Grade = row[2]
            # 打字与印刷结果
            print "ID: %s, Name: %s, Grade: %d" %
                (ID, Name, Grade)
    except:
        print "Error: unable to fecth data"

2、对象的措施

def deletedb(db):
    # 使用cursor()方法得到操作游标 
    cursor = db.cursor()
   # SQL 删除语句
    sql = "DELETE FROM Student WHERE Grade = '%d'" % (100)

close() 关闭

    try:
       # 执行SQL语句
       cursor.execute(sql)
       # 提交修改
       db.commit()
    except:
        print '删除数据失败!'
        # 发生错误时回滚
        db.rollback()

commit() 提交

def updatedb(db):
    # 使用cursor()方法获得操作游标 
    cursor = db.cursor()
    # SQL 更新语句
    sql = "UPDATE Student SET Grade = Grade + 3 WHERE ID = '%s'" % ('003')
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 提交到数据库实践
        db.commit()
    except:
        print '更新数据失利!'
        # 产生错误时回滚
        db.rollback()
def closedb(db):
    db.close()

cursor() 再次回到Cursor对象,用于施行sql语句并赢得结果

def main():
    db = connectdb()    # 连接MySQL数据库

execute(operation,[,parameters]) 实施语句,重临受影响的函数,主要用以实践insert,update,delete语句,也可用于实行create,alter,drop等

    createtable(db)     # 创建表
    insertdb(db)        # 插入数据
    print 'n插入数据后:'
    querydb(db) 
    deletedb(db)        # 删除数据
    print 'n删除数据后:'
    querydb(db)
    updatedb(db)        # 更新数据
    print 'n更新数据后:'
    querydb(db)

fetchone() 试行查询语句时,获取查询结果集的率先行数据,重回三个元祖

    closedb(db)         # 关闭数据库

fetchall() 推行查询时,获取结果集的持有行数,一行构成叁个元祖,再讲那几个元组装一个元组再次回到

if __name__ == '__main__':
    main()

fetchmany 实施查询时,要取的数额条数,n为要取的条数

#!/usr/bin/env python
import MySQLdb  
   
try:  
   conn=MySQLdb.connect(host='localhost',user='root',passwd='root',db='test',port=3306)  
    cur=conn.cursor()  
    cur.execute('select user,password from user')  
大奖888,    cur.close()  
    conn.close()  
except MySQLdb.Error,e:  
     print "Mysql Error %d: %s" % (e.args[0], e.args[1])   

Cursor对象

#!/usr/bin/env python  
#_*_ coding:utf-8 _*_  
  
import MySQLdb  
  
  
try:  
    conn =MySQLdb.Connect(host='192.168.8.40',user='root',passwd='root',db='mysql',port=3306)  
      
    cur = conn.cursor()  
    rs = cur.execute('select user,password,host from user')  
    rs = cur.execute('create database if not exists python')  
    conn.select_db('python')  
      
    cur.execute('create table test(id int,info varchar(30))')   
      
    value = [1,'hi jack']  
      
    cur.execute('insert into test values(%s,%s)',value)  
      
    values = []  
    for i in range(20):  
        values.append((i,'hi jack' + str(i)))  
          
    cur.executemany('insert into test values(%s,%s)',values)  
      
    cur.execute('update test set info="i am jack" where id=3')  
      
    conn.commit()  
    cur.close()  
    conn.close()  
except MySQLdb.Error,e:  
    print 'mysql error msg: %d,%s' % (e.args[0],e.args[1])   

功效:用于试行sql语句,常用的是增加和删除改查,获取cursor对象,调用Connection对象的cursor()方法cs=conn.cursor()

import MySQLdb  
    
try:  
    conn =MySQLdb.Connect(host='192.168.8.40',user='root',passwd='root',db='mysql',port=3306,charset='utf8')  
      
    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  
      
    result2 = cur.fetchmany(3)  
    for record in result2:  
        print record  
          
    print '=='*10  
    cur.scroll(0,mode='absolute')  
      
    result3 = cur.fetchall()  
    for record in result3:  
        print record[0] ,'---',record[1]  
      
    conn.commit()  
    cur.close()  
    conn.close()  
except MySQLdb.Error,e:  
    print 'mysql error msg: %d,%s' % (e.args[0],e.args[1]) 

目的的习性

询问后中文会呈现乱码,但在数据库中却是符合规律的,开掘用贰脾质量有可解决:

rowcount 只读属性,表示前段时间三回execute()实践受影响的行数

在Python代码 

connection 得到当前接连对象from pymysql import *

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'。 

def main():

下一场,那些延续对象也提供了对职业操作的帮衬,标准的方法
commit() 提交
rollback() 回滚

# 必须要有固定的:创制connection连接

cursor用来推行命令的法门:
callproc(self, procname, args):用来实践存款和储蓄进度,接收的参数为存款和储蓄进度名和参数列表,重返值为受影响的行数
execute(self, query, args):试行单条sql语句,接收的参数为sql语句小编和平运动用的参数列表,再次来到值为受影响的行数
executemany(self, query, args):实行单挑sql语句,可是再度试行参数列表里的参数,重回值为受影响的行数
nextset(self):移动到下贰个结出集

conn = connect(host='locahost', port=3306, database='test', user='test', password='123456', charset='utf8')

cursor用来接收重返值的主意:
fetchall(self):接收整体的回来结果行.
fetchmany(self, size=None):接收size条回来结果行.假诺size的值大于重返的结果行的多少,则会回到cursor.arraysize条数据.
fetchone(self):重临一条结果行.
scroll(self, value, mode='relative'):移动指针到某一行.倘若mode='relative',则意味从此时此刻所在行活动value条,如若mode='absolute',则表示从结果集的率先行活动value条.

# 必必要有固定的:获取Cursor对象

  1. PyMySQL 的使用

cs = conn.cursor()

(1) 什么是 PyMySQL?

# 执行select语句,并赶回查询的结果条数

  PyMySQL 是 Python 中用于连接 MySQL 服务器的二个库,它遵循 Python 数据库 API 标准 V2.0,并包括了 pure-Python MySQL 客户端库。

count = cs.execute

(2) 安装 PyMysql:

# 打印重临的询问结果行数

pip install PyMysql

print("查询到%d条数据:" % count)

(3) 使用 PyMySQL:

for i in range:

#!/usr/bin/env python
# coding=utf-8

# 获取查询结果,取一行数据,仅再次来到贰个元祖

import pymysql

result = cs.fetchone()

def connectdb():
    print('连接到mysql服务器...')
    # 展开数据库连接
    # 客商名:p, 密码:12345.,顾客名和密码须求改成你自个儿的mysql客商名和密码,而且要创制数据库TESTDB,并在TESTDB数据库中开创好表Student
    db = pymysql.connect("localhost","hp","Hp12345.","TESTDB")
    print('连接上了!')
    return db

# 打字与印刷查询结构

def createtable(db):
    # 使用cursor()方法获得操作游标 
    cursor = db.cursor()

print

    # 如果存在表Sutdent先删除
    cursor.execute("DROP TABLE IF EXISTS Student")
    sql = """CREATE TABLE Student (
            ID CHAR(10) NOT NULL,
            Name CHAR(8),
            Grade INT )"""

"""

    # 创建Sutdent表
    cursor.execute(sql)

取多行数据

def insertdb(db):
    # 使用cursor()方法赢得操作游标 
    cursor = db.cursor()

result1=fetchmany

    # SQL 插入语句
    sql = """INSERT INTO Student
         VALUES ('001', 'CZQ', 70),
                ('002', 'LHQ', 80),
                ('003', 'MQ', 90),
                ('004', 'WH', 80),
                ('005', 'HP', 70),
                ('006', 'YF', 66),
                ('007', 'TEST', 100)"""

result2=fetchall() # 再次来到的结果是元组里嵌元组

    #sql = "INSERT INTO Student(ID, Name, Grade)
    #    VALUES ('%s', '%s', '%d')" %
    #    ('001', 'HP', 60)
    try:
        # 执行sql语句
        cursor.execute(sql)
        # 提交到数据库实践
        db.commit()
    except:
        # Rollback in case there is any error
        print '插入数据退步!'
        db.rollback()

print

def querydb(db):
    # 使用cursor()方法得到操作游标 
    cursor = db.cursor()

"""

    # SQL 查询语句
    #sql = "SELECT * FROM Student
    #    WHERE Grade > '%d'" % (80)
    sql = "SELECT * FROM Student"
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 获取拥有记录列表
        results = cursor.fetchall()
        for row in results:
            ID = row[0]
            Name = row[1]
            Grade = row[2]
            # 打字与印刷结果
            print "ID: %s, Name: %s, Grade: %d" %
                (ID, Name, Grade)
    except:
        print "Error: unable to fecth data"

# 必供给有定点的:关闭cursor对象

def deletedb(db):
    # 使用cursor()方法取得操作游标 
    cursor = db.cursor()

cs.close()

    # SQL 删除语句
    sql = "DELETE FROM Student WHERE Grade = '%d'" % (100)

conn.close()

    try:
       # 执行SQL语句
       cursor.execute(sql)
       # 提交修改
       db.commit()
    except:
        print '删除数据失利!'
        # 产生错误时回滚
        db.rollback()

if __name__ == "__main__":

def updatedb(db):
    # 使用cursor()方法获得操作游标 
    cursor = db.cursor()

main()

    # SQL 更新语句
    sql = "UPDATE Student SET Grade = Grade + 3 WHERE ID = '%s'" % ('003')

大奖888 1

    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 提交到数据库试行
        db.commit()
    except:
        print '更新数据退步!'
        # 发生错误时回滚
        db.rollback()

def closedb(db):
    db.close()

def main():
    db = connectdb()    # 连接MySQL数据库

    createtable(db)     # 创建表
    insertdb(db)        # 插入数据
    print 'n插入数据后:'
    querydb(db) 
    deletedb(db)        # 删除数据
    print 'n删除数据后:'
    querydb(db)
    updatedb(db)        # 更新数据
    print 'n更新数据后:'
    querydb(db)

    closedb(db)         # 关闭数据库

if __name__ == '__main__':
    main() 

import pymysql  
  
# 展开数据库连接(ip/数据库客商名/登入密码/数据库名)  
db = pymysql.connect("localhost", "root", "root", "test")  
# 使用 cursor() 方法成立五个游标对象 cursor  
cursor = db.cursor()  
  
# 使用 execute()  方法推行 SQL 查询  
cursor.execute("SELECT VERSION()")  
# 使用 fetchone() 方法得到单条数据.  
data = cursor.fetchone()  
print("Database version : %s " % data)  
  
# 关闭数据库连接  
db.close()   

import pymysql  
  
# 张开数据库连接(ip/数据库顾客名/登入密码/数据库名)  
db = pymysql.connect("localhost", "root", "root", "test")  
# 使用 cursor() 方法创造一个游标对象 cursor  
cursor = db.cursor()  
  
# SQL 插入语句  
sql = """INSERT INTO user(name) 
         VALUES ('Mac')"""  
try:  
   # 执行sql语句  
   cursor.execute(sql)  
   # 提交到数据库实施  
   db.commit()  
except:  
   # 倘若发生错误则回滚  
   db.rollback()  
  
# 关闭数据库连接  
db.close()   

import pymysql  
  
# 展开数据库连接(ip/数据库客户名/登入密码/数据库名)  
db = pymysql.connect("localhost", "root", "root", "test")  
# 使用 cursor() 方法创造一个游标对象 cursor  
cursor = db.cursor()  
  
# SQL 查询语句  
sql = "SELECT * FROM user"  
  
try:  
    # 执行SQL语句  
    cursor.execute(sql)  
    # 获取具备记录列表  
    results = cursor.fetchall()  
    for row in results:  
        id = row[0]  
        name = row[1]  
        # 打字与印刷结果  
        print("id=%s,name=%s" %  
              (id, name))  
except:  
    print("Error: unable to fecth data")  
  
# 关闭数据库连接  
db.close()  

import pymysql  
  
# 展开数据库连接(ip/数据库客户名/登入密码/数据库名)  
db = pymysql.connect("localhost", "root", "root", "test")  
# 使用 cursor() 方法成立八个游标对象 cursor  
cursor = db.cursor()  
  
# SQL 更新语句  
sql = "UPDATE user SET name = 'Bob' WHERE id = 1"  
try:  
    # 执行SQL语句  
    cursor.execute(sql)  
    # 提交到数据库实施  
    db.commit()  
except:  
    # 产生错误时回滚  
    db.rollback()  
     
# 关闭数据库连接  
db.close()  

import pymysql  
  
# 展开数据库连接(ip/数据库顾客名/登陆密码/数据库名)  
db = pymysql.connect("localhost", "root", "root", "test")  
# 使用 cursor() 方法创造叁个游标对象 cursor  
cursor = db.cursor()  
  
# SQL 删除语句  
sql = "DELETE FROM user WHERE id  = 1"  
try:  
    # 执行SQL语句  
    cursor.execute(sql)  
    # 提交修改  
    db.commit()  
except:  
    # 发生错误时回滚  
    db.rollback()  
  
# 关闭数据库连接  
db.close()  

  1. mysql.connector 的使用

(1) 什么是 mysql.connector?

  由于 MySQL 服务器以独立的经过运营,并经过网络对外地劳工务,所以,必要帮衬Python 的 MySQL 驱动来连接受 MySQL 服务器。

目前,有两个 MySQL 驱动:

mysql-connector-python:是 MySQL 官方的纯 Python 驱动;

MySQL-python :是包裹了 MySQL C驱动的 Python 驱动。

(2) 安装 mysql.connector:

pip install mysql-connector-python
pip install MySQL-python

(3) 使用 mysql.connector:

#!/usr/bin/env python
# coding=utf-8

import mysql.connector

def connectdb():
    print('连接到mysql服务器...')
    # 张开数据库连接
    # 客商名:p, 密码:12345.,客户名和密码要求改成你本身的mysql顾客名和密码,並且要成立数据库TESTDB,并在TESTDB数据库中开创好表Student
    db = mysql.connector.connect(user="p", passwd="12345.", database="TESTDB",use_unicode=True)
    print('连接上了!')
    return db

def createtable(db):
    # 使用cursor()方法获得操作游标 
    cursor = db.cursor()

    # 即便存在表Sutdent先删除
    cursor.execute("DROP TABLE IF EXISTS Student")
    sql = """CREATE TABLE Student (
            ID CHAR(10) NOT NULL,
            Name CHAR(8),
            Grade INT )"""

    # 创建Sutdent表
    cursor.execute(sql)

def insertdb(db):
    # 使用cursor()方法获得操作游标 
    cursor = db.cursor()

    # SQL 插入语句
    sql = """INSERT INTO Student
         VALUES ('001', 'CZQ', 70),
                ('002', 'LHQ', 80),
                ('003', 'MQ', 90),
                ('004', 'WH', 80),
                ('005', 'HP', 70),
                ('006', 'YF', 66),
                ('007', 'TEST', 100)"""

    #sql = "INSERT INTO Student(ID, Name, Grade)
    #    VALUES ('%s', '%s', '%d')" %
    #    ('001', 'HP', 60)
    try:
        # 执行sql语句
        cursor.execute(sql)
        # 提交到数据库试行
        db.commit()
    except:
        # Rollback in case there is any error
        print '插入数据战败!'
        db.rollback()

def querydb(db):
    # 使用cursor()方法获得操作游标 
    cursor = db.cursor()

    # SQL 查询语句
    #sql = "SELECT * FROM Student
    #    WHERE Grade > '%d'" % (80)
    sql = "SELECT * FROM Student"
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 获取具备记录列表
        results = cursor.fetchall()
        for row in results:
            ID = row[0]
            Name = row[1]
            Grade = row[2]
            # 打字与印刷结果
            print "ID: %s, Name: %s, Grade: %d" %
                (ID, Name, Grade)
    except:
        print "Error: unable to fecth data"

def deletedb(db):
    # 使用cursor()方法获得操作游标 
    cursor = db.cursor()

    # SQL 删除语句
    sql = "DELETE FROM Student WHERE Grade = '%d'" % (100)

    try:
       # 执行SQL语句
       cursor.execute(sql)
       # 提交修改
       db.commit()
    except:
        print '删除数据失利!'
        # 产生错误时回滚
        db.rollback()

def updatedb(db):
    # 使用cursor()方法赢得操作游标 
    cursor = db.cursor()

    # SQL 更新语句
    sql = "UPDATE Student SET Grade = Grade + 3 WHERE ID = '%s'" % ('003')

    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 提交到数据库推行
        db.commit()
    except:
        print '更新数据战败!'
        # 发生错误时回滚
        db.rollback()

def closedb(db):
    db.close()

def main():
    db = connectdb()    # 连接MySQL数据库

    createtable(db)     # 创建表
    insertdb(db)        # 插入数据
    print 'n插入数据后:'
    querydb(db) 
    deletedb(db)        # 删除数据
    print 'n删除数据后:'
    querydb(db)
    updatedb(db)        # 更新数据
    print 'n更新数据后:'
    querydb(db)

    closedb(db)         # 关闭数据库

if __name__ == '__main__':
    main()











​#!/usr/bin/python  
#coding=utf-8  
  
import mysql.connector  
from mysql.connector import errorcode  
  
class mysqlconnectordemo(object):  
    def __init__(self):  
        pass  
    def connect(self,conf):  
        try:  
            conn = mysql.connector.connect(**conf)  
            print("conn success!")  
        except mysql.connector.Error as err:  
            if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:  
                print("Something is wrong with your user name or password")  
            elif err.errno == errorcode.ER_BAD_DB_ERROR:  
                print("Database does not exist")  
            else:  
                print(err)  
        else:  
            conn.close()  
  
    def query(self,conf,sql):  
        try:  
            conn = mysql.connector.connect(**conf)  
            print("conn success!")  
            cursor = conn.cursor()  
            try:  
                cursor.execute(sql)  
                values = cursor.fetchall()#回去是二个由元组构成的list,每七个元组是一行值  
                print type(values)  
                for i in values:  
                    print i  
            except mysql.connector.Error as err:  
                print('query datas error!{}'.format(err))  
        except mysql.connector.Error as err:  
            if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:  
                print("Something is wrong with your user name or password")  
            elif err.errno == errorcode.ER_BAD_DB_ERROR:  
                print("Database does not exist")  
            else:  
                print(err)  
        else:  
            conn.close()  
  
    def insert(self,conf,sql):  
        try:  
            conn = mysql.connector.connect(**conf)  
            print("conn success!")  
            cursor = conn.cursor()  
            try:  
                cursor.execute(sql)  
                conn.commit()  
                cursor.close()  
            except mysql.connector.Error as err:  
                print('insert datas error!{}'.format(err))  
        except mysql.connector.Error as err:  
            if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:  
                print("Something is wrong with your user name or password")  
            elif err.errno == errorcode.ER_BAD_DB_ERROR:  
                print("Database does not exist")  
            else:  
                print(err)  
        else:  
            conn.close()     

#!/usr/bin/python  
#coding=utf-8  
  
import MySQLdb  
  
class mysqldbdemo(object):  
    def __init__(self):  
        pass  
    def connect(self):  
        conn = MySQLdb.connect("host_ip","user","password","database")  
        conn.close()  
  
    def query(self,sql):  
        conn = MySQLdb.connect("host_ip","user","password","database")  
        cursor = conn.cursor()  
        try:  
            cursor.execute(sql)  
            values = cursor.fetchall()#归来是贰个由元组构成的tuple,每二个元组是一行值  
            print type(values)  
            for i in values:  
                print i  
        except:  
            print "Error: unable to fecth data"  
        conn.close()  
  
    def insert(self,sql):  
        conn = MySQLdb.connect("host_ip","user","password","database")  
        cursor = conn.cursor()  
        try:  
            cursor.execute(sql)  
            conn.commit()  
        except:  
            conn.rollback()  
        conn.close()  

版权声明:本文由大奖888-www.88pt88.com-大奖888官网登录发布于网络数据,转载请注明出处:它实现了 Python 数据库,因为我们不可能去构造出