[大数据]【无标题】python和pymysql小型案例程序分析-球员信息管理系统01

程序设计思路

第一、建立数据库结构

第二、链接数据库并建立增删改查

建立数据库（由navicat导出）

/*
Navicat MySQL Data Transfer

Source Server ? ? ? ? : test
Source Server Version : 50624
Source Host ? ? ? ? ? : localhost:3306
Source Database ? ? ? : test_3

Target Server Type ? ?: MYSQL
Target Server Version : 50624
File Encoding ? ? ? ? : 65001

Date: 2021-11-29 21:43:08
*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for fifa
-- ----------------------------
DROP TABLE IF EXISTS `fifa`;
CREATE TABLE `fifa` (
? `ID` int(11) NOT NULL,
? `people_name` varchar(255) DEFAULT NULL,
? `PAC` int(11) DEFAULT NULL,
? `DRI` int(11) DEFAULT NULL,
? `SHO` int(11) DEFAULT NULL,
? `DEF` int(11) DEFAULT NULL,
? `PAS` int(11) DEFAULT NULL,
? `PHY` int(11) DEFAULT NULL,
? `score` int(11) DEFAULT NULL,
? PRIMARY KEY (`ID`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

数据库建立完毕之后，基础代码，数据链接类，实现数据库链接关闭基本功能，官方代码如下

import pymysql
class Mysqlpython:
    #带关键字默认值构造参数，定义对象的时候自动赋值
    def __init__(self, database='test_3', host='127.0.0.1', user="root",
    password='1234', port=3306, charset="utf8"):
        self.host = host
        self.user = user
        self.password = password
        self.port = port
        self.database = database
        self.charset = charset
        print('self.host==',self.host)

    #通过pymysql建立数据库链接对象，和前几天的教程一样
    def open(self):
        self.db =pymysql.connect(host=self.host, user=self.user,
        password=self.password, port=self.port,
        database=self.database,
        charset=self.charset)

        #通过数据库链接对象建立游标对象，方便对数据库的增删改查操作
        self.cur = self.db.cursor()

    #数据库关闭方法
    def close(self):
        self.cur.close()
        self.db.close()
    #查询方法 和 增删改 前者用fetchall获取数据集，后者需要commit到数据库操作
    #数据库执行操作方法增删改
    def Operation(self, sql):
        try:
            self.open()
            self.cur.execute(sql)
            self.db.commit()
            print("ok")
        except Exception as e:
            self.db.rollback()
            print("Failed", e)
            self.close()

    #数据库查询所有操作方法-查询方法
    def Search(self, sql):
        try:
            self.open()
            self.cur.execute(sql)
            result = self.cur.fetchall()
            return result
        except Exception as e:
            print("Failed", e)
            self.close()

今天先到这里，明天更新后半部分代码程序，后面就是根据用户的选择来操作增删改查的参数带入，调用类里面对应的方法。