数据库存储 for MySQL

50 阅读 0 评论 33 点赞

我是靠谱客的博主执着汉堡，最近开发中收集的这篇文章主要介绍数据库存储 for MySQL，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

mysql是关系型数据库

以下几个函数和方法,绝大多数数据库都可以操作使用

connect函数:连接数据库,根据连接的数据库类型不同,该函数的参数也不同。connect函数返回Connecting对象。

cursor方法：获取操作数据库的Cursor对象。cursor方法属于Connecting对象。

execute方法：用于执行sql语句，该方法属于Cursor对象。

commit方法：在修改数据库后，需要调用该方法提交对数据库的修改，commit方法属于Cursor对象。

rollback方法：如果修改数据库失败，一般需要调用该方法进行数据库回调，也就是把数据库恢复未之前修改的样子。

from pymysql import *
import json
# 打开mysql数据库
def connectDB():
    db=connect(user="root",password="123456",host="127.0.0.1",database="test",charset='utf8')
    return db
db=connectDB()
# 创建person表
def creatTable(db):
    # 获取cursor对象
    cursor=db.cursor()
    sql="""CREATE TABLE persons
      (id INT PRIMARY KEY NOT NULL,
      name TEXT NOT NULL,
      age INT NOT NULL,
      address CHAR(50),
      salary REAL);"""
    try:
        # 执行创建表的sql语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
        return True
    except:
        # 如果发生错误的回读
        db.rollback()
    return False
# 向persons表插入4条记录
def insertRecords(db):
    cursor=db.cursor()
    try:
        # 首先将以前插入的记录全部删除
        cursor.execute("DELETE FROM persons")
        # 下面的几条语句向persons表中插入4条记录
        cursor.execute("INSERT INTO persons(id,name,age,address,salary)"
                  " VALUES(1,'Paul',32,'California',20000.00)")
        cursor.execute("INSERT INTO persons(id,name,age,address,salary)"
                  "VALUES(2,'Allen',25,'Texas',15000.00)")
        cursor.execute("INSERT INTO persons(id,name,age,address,salary)"
                  "VALUES(3,'Teddy',23,'Norway',20000.00)")
        cursor.execute("INSERT INTO persons(id,name,age,address,salary)"
                  "VALUES(4,'Mark',25,'Rich-Mond',65000.00)")
        # 提交到数据库
        db.commit()
        return True
    except Exception as e:
        print(e)
        # 如果发生错误回滚
        db.rollback()
    return False
# 查询persons表中的全部记录,并按age字段降序排列
def selectRecords(db):
    cursor=db.cursor()
    sql="SELECT name,age,salary FROM persons ORDER BY age DESC"
    cursor.execute(sql)
    # 调用fetchall方法获取全部记录
    results=cursor.fetchall()
    # 输出查询结果
    print(results)
    # 下面的代码将查询结果重新组织或其他形式
    fields=['name','age','salary']
    records=[]
    for row in results:
        records.append(dict(zip(fields,row)))
    return json.dumps(records)

if creatTable(db):
    print('成功创建persons表')
else:
    print('persons表已经存在')

if insertRecords(db):
    print('成功插入数据')
else:
    print('插入数据失败')
print(selectRecords(db))
db.close()

结果: