python 连接mysql

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了python 连接mysql，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3325字，纯文字阅读大概需要5分钟。

内容图文

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

import MySQLdb

def connectdb():
    print(‘连接到mysql服务器...‘)
    # 打开数据库连接
    # 用户名:root, 密码:root.,用户名和密码需要改成你自己的mysql用户名和密码，并且要创建数据库TEST，并在TEST数据库中创建好表Student
    db = MySQLdb.connect("localhost","root","root","test")
    print(‘连接上了!‘)
    return db

#删除表
def dropteble(db,sql):
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()
    # 如果存在表Sutdent先删除
    cursor.execute(sql)

#创建表
def createtable(db,sql):
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()
    cursor.execute(sql)

#插入数据
def insertdb(db,sql):
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()

    try:
        # 执行sql语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print ‘插入数据成功!‘
    except:
        # Rollback in case there is any error
        print ‘插入数据失败!‘
        db.rollback()

#查询
def querydb(db,sql):
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 获取所有记录列表
        results = cursor.fetchall()
        for row in results:
            print row
    except:
        print "Error: unable to fecth data"

#删除
def deletedb(db,sql):
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 提交修改
        db.commit()
        print ‘删除数据成功!‘
    except:
        print ‘删除数据失败!‘
        # 发生错误时回滚
        db.rollback()

#修改
def updatedb(db,sql):
    # 使用cursor()方法获取操作游标
    cursor = db.cursor()
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        print ‘修改数据成功!‘
    except:
        print ‘更新数据失败!‘
        # 发生错误时回滚
        db.rollback()

#关闭资源
def closedb(db):
    db.close()



def main():
    dropteble_sql=‘DROP TABLE IF EXISTS Student‘

    createtable_sql="""CREATE TABLE Student (
            ID CHAR(10) NOT NULL,
            Name CHAR(8),
            Grade INT )"""

    insertdb_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)"""

    querydb_sql="SELECT * FROM Student"
    deletedb_sql="DELETE FROM Student WHERE Grade = ‘%d‘" % (100)
    updatedb_sql="UPDATE Student SET Grade = Grade + 3 WHERE ID = ‘%s‘" % (‘003‘)

    db = connectdb()    # 连接MySQL数据库
    dropteble(db,dropteble_sql) #删除表
    createtable(db,createtable_sql)     # 创建表
    insertdb(db,insertdb_sql)        # 插入数据
    print ‘\n插入数据后:‘
    querydb(db,querydb_sql)
    deletedb(db,deletedb_sql)        # 删除数据
    print ‘\n删除数据后:‘
    querydb(db,querydb_sql)
    updatedb(db,updatedb_sql)        # 更新数据
    print ‘\n更新数据后:‘
    querydb(db,querydb_sql)

    closedb(db)         # 关闭数据库


if __name__ == ‘__main__‘:
    main()

python 连接mysql

标签：失败   nec   __name__   存在   回滚   for   update   post   l数据库   

本文系统来源：https://www.cnblogs.com/Jerry1104/p/8359923.html

内容总结

以上是互联网集市为您收集整理的python 连接mysql全部内容，希望文章能够帮你解决python 连接mysql所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端