鱼C论坛

 找回密码
 立即注册
查看: 626|回复: 2

请问各位:数据库数据要怎么用python提取?

[复制链接]
发表于 2024-3-15 10:42:10 | 显示全部楼层 |阅读模式

马上注册,结交更多好友,享用更多功能^_^

您需要 登录 才可以下载或查看,没有账号?立即注册

x
请问各位:MySql数据库数据要怎么用python提取?
想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
回复

使用道具 举报

发表于 2024-3-15 16:15:15 | 显示全部楼层
一段封装的mysql代码,可以借鉴下
import pymysql


class MySqlModel(object):
    def __init__(self, host, user, password, dbName):
        self.host = host
        self.user = user
        self.password = password
        self.dbName = dbName

    def connet(self):
        self.db = pymysql.connect(self.host, self.user, self.password, self.dbName)
        self.cursor = self.db.cursor()

    def close(self):
        self.cursor.close()
        self.db.close()

    def get_on(self, sql):
        """
        instance_sql:说明
            从数据的table_name表,选择numeric字段最小的一条数据
        """
        instance_sql = f"SELECT MIN(numeric) FROM table_name ;"
        res = None
        try:
            self.connet()
            self.cursor.execute(sql)
            res = self.cursor.fetchone()
            self.close()
        except:
            print("查询失败")
        return res

    def get_all(self, sql):
        res = ()
        try:
            self.connet()
            self.cursor.execute(sql)
            res = self.cursor.fetchall()
            self.close()
        except:
            print("查询失败")
        return res

    def insert(self, sql):
        """
        instance_sql:说明
            插入一条value数据到table_name表中
        """
        value = (0, "ein", "tom", 10, 0)
        table_name = "ILOVEFISHC"
        instance_sql = f"insert into {table_name} values {value};"
        return self._deit(sql)

    def update(self, sql):
        """
        update 表名 set 字段=新值,… where 条件
        instance_sql说明:
            更新table_name表的numeric字段,条件是numeric等于result
        """
        numeric = ""
        result = "6"
        instance_sql = f"update table_name set numeric ={numeric} where numeric ={result};"
        return self._deit(sql)

    def delete(self, sql):
        return self._deit(sql)

    def create(self, sql):
        return self._deit(sql)

    def _deit(self, sql):
        count = 0
        try:
            self.connet()
            count = self.cursor.execute(sql)
            self.db.commit()
            self.close()
        except:
            print("事务提交失败")
            self.db.rollback()
        return count
想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
回复 支持 反对

使用道具 举报

 楼主| 发表于 2024-3-15 16:34:52 | 显示全部楼层
Stubborn 发表于 2024-3-15 16:15
一段封装的mysql代码,可以借鉴下

谢谢~~
想知道小甲鱼最近在做啥?请访问 -> ilovefishc.com
回复 支持 反对

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

小黑屋|手机版|Archiver|鱼C工作室 ( 粤ICP备18085999号-1 | 粤公网安备 44051102000585号)

GMT+8, 2024-11-15 10:27

Powered by Discuz! X3.4

© 2001-2023 Discuz! Team.

快速回复 返回顶部 返回列表