您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站
首页- 博文- python- 学Python划重点 六 (数据库实列编程)

学Python划重点 六 (数据库实列编程)

bubuko 2022/1/25 19:50:29 python 字数 33043 阅读 981 来源 http://www.bubuko.com/infolist-5-1.html

Python 中将数据保存到数据库中技术有很多，但主要分为两类：遵循Python DB-API 规范技术(Python Database API Specification) 和ORM 技术(Object-Relational mapping) 。Python DB-API 规范通过在Python ...

Python 中将数据保存到数据库中技术有很多，但主要分为两类：遵循Python DB-API 规范技术(Python Database API Specification) 和ORM 技术(Object-Relational mapping) 。Python DB-API 规范通过在Python 中编写SQL 语句访问数据库。ORM 技术是面向对象的，对数据的访问是通过对象实现的，程序员不需要使用SQL 语句。

在Python2.X 中操作MySQL 数据库可以通过Pyhon 的MySQLdb 模块实现，由于目前Python3.5 不支持MySQLdb 模块，所以我们使用pymysql 模块。

下面介绍数据库的基本操作步骤： 在这里插入图片描述

==1. 创建数据库连接==

import pymysql
#连接数据库
conn = pymysql.connect(
host=‘localhost‘,  # 数据库主机名或IP
port=3306          # 连接数据库端口号
user=‘root‘,       # 访问数据库帐号
password=‘1234‘,   # 访问数据库密码
database=‘mydatabase‘,  # 数据库中的库名
charset=‘utf8‘)    # 数据库编码格式

Connection 对象有一些重要的方法 ： close() ：关闭数据库连接，关闭之后再使用数据库连接将引发异常。 commit() ：提交数据库事务。 rollback() ：回滚数据库事务。 cursor() ：获得Cursor 游标对象。

==2. 创建游标==

一个Cursor 游标对象表示一个数据库游标，游标暂时保存了SQL 操作所影响到的数据。 在数据库事务管理中游标非常重要，游标是通过数据库连接创建的，相同数据库连接创 建的游标所引起的数据变化，会马上反映到同一连接中的其他游标对象。但是不同数据 库连接中的游标，是否能及时反映出来，则与数据库事务管理有关。

游标Cursor 对象方法： 1.execute(operation[, parameters]) 执行一条SQL 语句，operation 是SQL 语句，parameters 是为SQL 提供的参数，可以是 序列或 字典 类型。返回值是整数，表示执行SQL 语句影响的行数。 2. executemany(operation[, seq_of_params]) 执行批量SQL 语句，operation 是SQL 语句，seq_of_params 是为SQL 提供的参数， seq_of_params 是 序列 。返回值是整数，表示执行SQL 语句影响的行数。 3.callproc(procname[, parameters]) 执行存储过程，procname 是存储过程名，parameters 是为存储过程提供的参数。 4.fetchone() 从结果集中返回一条记录的序列，如果没有数据返回None 。 5.fetchmany([size=cursor.arraysize) 从结果集中返回小于或等于size 的记录数序列，如果没有数据返回空序列，size 默认情况下是整个游标的行数。 6.fetchall() 从结果集中返回所有数据。

实列：

1. 创建数据库：

import pymysql
#  连接数据库
conn = pymysql.connect(
host=‘127.0.0.1‘,
port=3306,
user=‘root‘,
password=‘1234‘,
charset=‘utf8‘
)
cursor = conn.cursor() #  拿到游标
cursor.execute("create database if not exists mydatabase") #  创建数据库
cursor.close() # 关闭游标
conn.close() # 关闭连接

2. 创建数据库表：

import pymysql
#  连接数据库
conn = pymysql.connect(
host=‘127.0.0.1‘,
port=3306,
user=‘root‘,
password=‘1234‘,
db=‘mydatabase‘,
charset=‘utf8‘
)
cursor = conn.cursor()  # 拿到游标
cursor.execute(‘‘‘create table if not exists student (
number varchar(20) primary key,
name varchar(50) not null,
sex varchar(2) check (sex in(‘M’,‘F’)),
math double(4,1),
english double(4,1),
computer double(4,1)
‘‘‘)
cursor.close()
conn.close()

3. 插入数据：

import pymysql
# 1.  创建数据库连接
conn = pymysql.connect(
host=‘127.0.0.1‘,
port=3306,
user=‘root‘,
password=‘1234‘,
db=‘mydatabase‘
charset=‘utf8‘
)
try:
 # 2. 创建游标对象
 with conn.cursor() as cursor: #with 代码块结束时就会关闭游标对象。
  # 3. 执行sql 操作。插入多条语句
  sql = ‘insert into student(number, name, sex, math, english, computer) values (%s, %s, %s, %s, %s, %s)‘
  
  data = [
  (‘1501‘, ‘ 炎黄‘, ‘M‘, 78.5, 70.0, 100.0),
  (‘1505‘, ‘ 吕萌萌‘, ‘M‘, 100.0, 90.0, 95.0),
  (‘1509‘, ‘ 石耀举‘, ‘F‘, 60.5, 90.0, 70.0)
  ]
  cursor.executemany(sql, data)
  
  # 3.  执行sql 操作 。插入 单条 数据
  data = (‘1521‘, ‘ 王维‘, ‘F‘, 68.4, 73.0, 55.0)
  cursor.execute(sql, data) #  参数放在列表中，或放在元组中
  # 4.  提交数据库事务
  conn.commit()
 # with 代码块结束 5.  自动关闭游标
except pymysql.DatabaseError:
 conn.rollback()  # 4.  回滚数据库事务
finally:
 conn.close()# 6.  关闭数据库连接

4. 删除数据

import pymysql
# 1.  创建数据库连接
conn = pymysql.connect(
host=‘127.0.0.1‘,
port=3306,
user=‘root‘,
password=‘1234‘,
db=‘mydatabase‘
charset=‘utf8‘
)
try:
 # 2.  创建游标对象
 with conn.cursor() as cursor:
  # 3.  执行sql 语句
  sql = ‘delete from student where number=%s‘
  cursor.execute(sql, ‘1502‘)
  cursor.executemany(sql, (‘1505‘, ‘1507‘, ‘1514‘))
   # 4.  提交数据库事务
  conn.commit()
  # with 代码块结束 5.  关闭游标
except pymysql.DatabaseError:
 conn.rollback()# 4.  回滚数据库事务
finally:
 conn.close()# 6.  关闭数据库连接

5. 修改数据

import pymysql
# 1.  创建数据库连接
conn = pymysql.connect(
host=‘127.0.0.1‘,
port=3306,
user=‘root‘,
password=‘1234‘,
db=‘mydatabase‘
charset=‘utf8‘
)
try:
 #2.  创建游标对象
 with conn.cursor() as cursor:
  # 3.  执行sql 语句
  sql = ‘update student set name=%s where number > %s‘
  cursor.execute(sql, (‘ 水份‘, ‘1510‘))
  # 4.  提交数据库事务
  conn.commit()
 # with 代码块结束 5.  关闭游标
except pymysql.DatabaseError:
 # 4.  回滚数据库事务
 conn.rollback()
finally:
 # 6.  关闭数据库连接
 conn.close()

6. 查找数据

import pymysql
# 1.  创建数据库连接
conn = pymysql.connect(
host=‘127.0.0.1‘,
port=3306,
user=‘root‘,
password=‘1234‘,
db=‘mydatabase‘
charset=‘utf8‘
)
try:
# 2. 创建游标对象
with conn.cursor() as cursor:
 # 3. 执行sql 操作
 sql = ‘select * from student‘
 cursor.execute(sql)
 
 # 4. 提取结果集
 # 提取所有数据，返回结果默认是元组形式，所以可以进行迭代处理
 result_list = cursor.fetchall()
 for row in result_list:
 print(row)
 print(‘ 共查询到：‘, cursor.rowcount, ‘ 条数据。‘)
 
 # 4. 提取结果集。获取第一行数据
 result1 = cursor.fetchone()
 print(result1)
 
 # 4. 提取结果集。获取前n 行数据
 result2 = cursor.fetchmany(2)
 print(result2)
 # with 代码块结束 5.  关闭游标
finally:
 # 6.  关闭数据库连接
 conn.close()

7. 数据库配置文件的使用

配置文件configparser.ini

[db]
host = 127.0.0.1
port = 3306
user = root
password = 1234
database = mydatabase
charset = utf8

import pymysql
import configparser
config = configparser.ConfigParser()
config.read(‘config.ini‘, encoding=‘utf-8‘)
host = config[‘db‘][‘host‘]
port = config.getint(‘db‘, ‘port‘)
user = config[‘db‘][‘user‘]
password = config[‘db‘][‘password‘]
database = config[‘db‘][‘database‘]
charset = config[‘db‘][‘charset‘]

# 1. 创建数据库连接
conn = pymysql.connect(
host=host,
port=port,
user=user,
password=password,
database=database,
charset=charset
)

cursor 就是一个Cursor 对象，这个cursor 是一个实现了迭代器和生成器的对象，这个时候cursor 中还没有数据，只有等到fetchone() 或fetchall() 的时候才返回一个元组tuple ，才支持len() 和index() 操作，这也是它是迭代器的原因 。但同时为什么说它是生成器呢？因为cursor 只能用一次，即每用完一次之后记录其位置，等到下次再取的时候是从游标处再取而不是从头再来，而且fetch 完所有的数据之后，这个cursor 将不再有使用价值了，即不再能fetch 到数据了。

8. 学生管理系统

import pymysql
import wx
import wx.grid


class MyData():
    def __init__(self):
        self.tableText=["number","name","sex","math","english","computer"]
        self.mydata=[]
        self.conn = pymysql.connect(
            host="127.0.0.1",
            port=3306,
            user="root",
            password="123456",
            database="student",
            charset="utf8"
        )

    def Conn(self):
        self.conn = pymysql.connect(
            host="127.0.0.1",
            port=3306,
            user="root",
            password="123456",
            database="student",
            charset="utf8"
        )

    def showData(self,number):
        self.Conn()
        try:
            with self.conn.cursor() as cursor:
                self.mydata=[]
                if number=="":
                    sqlstr = "select * from test1"
                    cursor.execute(sqlstr, ())
                else:
                    sqlstr = "select * from test1 where number=%s"
                    cursor.execute(sqlstr, (number))

                result_list=cursor.fetchall()
                for item in result_list:
                    print(item)
                    self.mydata.append(item)
        except pymysql.DatabaseError:
            self.conn.rollback()
        finally:
            self.conn.close()

    def insterData(self,data):
        self.Conn()
        try:
            with self.conn.cursor() as cursor:
                sqlstr = """
                    insert into test1 (number,name,sex,math,english,computer)
                     values(%s,%s,%s,%s,%s,%s)
                    """
                cursor.execute(sqlstr, data)
                self.conn.commit()
        except pymysql.DatabaseError:
            self.conn.rollback()
        finally:
            self.conn.close()

    def uptateData(self,data):
        self.Conn()
        try:
            with self.conn.cursor() as cursor:
                sqlstr = "update test1 set number=%s,name= %s ,sex=%s,math=%s,english=%s,computer=%s where number=%s"
                cursor.execute(sqlstr, data)
                self.conn.commit()
        except pymysql.DatabaseError:
            self.conn.rollback()
        finally:
            self.conn.close()

    def deleteData(self,number):
        self.Conn()
        try:
            with self.conn.cursor() as cursor:
                sqlstr = "delete from test1 where number=%s"
                print(number)
                cursor.execute(sqlstr, number)
                self.conn.commit()
        except pymysql.DatabaseError:
            self.conn.rollback()
        finally:
            self.conn.close()
    def colse(self):
        self.conn.close()


class MyGridTable(wx.grid.GridTableBase):
    def __init__(self,tableText,data):
        super().__init__()
        self.tableText=tableText
        self.data=data
        self.colLabels=tableText
    def GetNumberRows(self):
        return len(self.data)
    def GetNumberCols(self):
        return len(self.tableText)
    def GetValue(self, row, col):
        return self.data[row][col]
    def GetColLabelValue(self, col):
        return self.tableText[col]

class AddorChangeFrame(wx.Frame):
    def __init__(self,frame):
        if frame=="添加":
            super().__init__(parent=None,size=(300,350),title="添加")
        else:
            super().__init__(parent=None, size=(300, 350), title="修改")
        self.Center()

        panel=wx.Panel(self)
        number=wx.StaticText(parent=panel,id=-1,label="学号")
        self.numbertext=wx.TextCtrl(parent=panel,id=-1)
        box1=wx.BoxSizer()
        box1.Add(number)
        box1.Add(self.numbertext)

        name = wx.StaticText(parent=panel, id=-1, label="姓名")
        self.nametext = wx.TextCtrl(parent=panel, id=-1)
        box2 = wx.BoxSizer()
        box2.Add(name)
        box2.Add(self.nametext)

        sex = wx.StaticText(parent=panel, id=-1, label="性别")
        self.sextext = wx.TextCtrl(parent=panel, id=-1)
        box3 = wx.BoxSizer()
        box3.Add(sex)
        box3.Add(self.sextext)

        math = wx.StaticText(parent=panel, id=-1, label="数学")
        self.mathtext = wx.TextCtrl(parent=panel, id=-1)
        box4 = wx.BoxSizer()
        box4.Add(math)
        box4.Add(self.mathtext)

        english = wx.StaticText(parent=panel, id=-1, label="英语")
        self.englishtext = wx.TextCtrl(parent=panel, id=-1)
        box5 = wx.BoxSizer()
        box5.Add(english)
        box5.Add(self.englishtext)

        computer = wx.StaticText(parent=panel, id=-1, label="学号")
        self.computertext = wx.TextCtrl(parent=panel, id=-1)
        box6 = wx.BoxSizer()
        box6.Add(computer)
        box6.Add(self.computertext)

        if frame=="添加":
            button1 = wx.Button(parent=panel, id=2, label="添加")
        else:
            button1=wx.Button(parent=panel,id=3,label="修改")
        button2 = wx.Button(parent=panel, id=1, label="取消")
        self.Bind(wx.EVT_BUTTON, self.on_button, id=1, id2=3)
        box7=wx.BoxSizer()
        box7.Add(button1)
        box7.Add(button2)


        mainbox=wx.BoxSizer(wx.VERTICAL)
        mainbox.Add(box1,1,flag=wx.ALL,border=5)
        mainbox.Add(box2,1,flag=wx.ALL,border=5)
        mainbox.Add(box3,1,flag=wx.ALL,border=5)
        mainbox.Add(box4,1,flag=wx.ALL,border=5)
        mainbox.Add(box5,1,flag=wx.ALL,border=5)
        mainbox.Add(box6,1,flag=wx.ALL,border=5)
        mainbox.Add(box7, 1, flag=wx.ALL, border=5)

        panel.SetSizer(mainbox)

    def on_button(self, event):
        id = event.GetId()
        number=self.numbertext.GetValue()
        name = self.nametext.GetValue()
        sex = self.sextext.GetValue()
        math = self.mathtext.GetValue()
        english=self.englishtext.GetValue()
        computer = self.computertext.GetValue()

        data = MyData()
        # 取消
        if id == 1:
            self.Close()
        # 添加
        elif id==2:
            data.insterData((number, name, sex, math, english, computer))
            self.Close()
        # 修改
        else:
            data.uptateData((number, name, sex, math, english, computer,number))
            self.Close()


class myFrame(wx.Frame):
    def __init__(self):
        super().__init__(parent=None,size=(700,400),title="学生信息管理系统")
        self.Center()

        panel=wx.Panel(self)

        box1=wx.BoxSizer(wx.HORIZONTAL)
        text1=wx.StaticText(parent=panel,id=-1,label="请输入学号:")
        self.inputtext=wx.TextCtrl(parent=panel,id=-1)
        findbutton=wx.Button(parent=panel,id=1,label="查询")
        deletebutton = wx.Button(parent=panel, id=4, label="删除")
        self.Bind(wx.EVT_BUTTON,self.on_button,id=1,id2=4)
        b = wx.BoxSizer(wx.HORIZONTAL)
        b.Add(text1,1,flag=wx.LEFT|wx.TOP|wx.BOTTOM,border=15)
        b.Add(self.inputtext, 1,flag=wx.ALL,border=10)
        b.Add(findbutton, 1,flag=wx.ALL,border=10)
        b.Add(deletebutton, 1, flag=wx.ALL, border=10)
        box1.Add(b,1,flag=wx.LEFT|wx.RIGHT,border=70)

        self.grid = wx.grid.Grid(parent=panel,size=(580,255))
        rowsizeinfo=wx.grid.GridSizesInfo(40,[])
        self.grid.SetRowSizes(rowsizeinfo)
        data=MyData()
        data.showData("")
        table = MyGridTable(data.tableText,data.mydata)
        self.grid.SetTable(table, True)
        box2 = wx.BoxSizer()
        box2.Add(self.grid)

        addbutton = wx.Button(parent=panel, id=2, label="添加")
        updatebutton = wx.Button(parent=panel, id=3, label="修改")


        box3 = wx.BoxSizer()
        box3.Add(addbutton,1,flag=wx.EXPAND)
        box3.Add(updatebutton, 1, flag=wx.EXPAND)


        mainbox = wx.BoxSizer(wx.VERTICAL)
        mainbox.Add(box1,1,flag=wx.EXPAND)
        mainbox.Add(box2, 1,flag=wx.EXPAND|wx.LEFT|wx.RIGHT,border=50)
        mainbox.Add(box3, 1,flag=wx.EXPAND)
        panel.SetSizer(mainbox)

    def on_button(self, event):
        id = event.GetId()
        data = MyData()
        if id == 1:
            data.showData(self.inputtext.GetValue())
            print("查询！！！")
        elif id==2:
            print("添加！！！")
            self.addFrame=AddorChangeFrame("添加")
            self.addFrame.Show()
        elif id == 3:
            self.addFrame = AddorChangeFrame("修改")
            self.addFrame.Show()
            print("修改！！")
        elif id == 4:
            data.deleteData(self.inputtext.GetValue())
            print("删除！！！")

        if id !=1:# 显示全部
            data.showData("")
        table = MyGridTable(data.tableText, data.mydata)
        self.grid.SetTable(table,True)


class myApp(wx.App):
    def OnInit(self):
        self.frame=myFrame()
        self.frame.Show()
        return True


if __name__=="__main__":
    app=myApp()
    app.MainLoop()

在这里插入图片描述 在这里插入图片描述

人生的光荣，不在于永不言败，而在于能够屡扑屡起 ！

本文使用 mdnice 排版

 

学Python划重点 六 (数据库实列编程)

原文：https://www.cnblogs.com/1837290753qq/p/12879679.html


如果您也喜欢它,动动您的小指点个赞吧

除非注明，文章均由 laddyq.com 整理发布，欢迎转载。

转载请注明：
链接：http://laddyq.com
来源：laddyq.com
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

联系我

联系我

602392714

清零编程清零编程群

置顶