使用Python实现Mysql数据库相关操作详解

pip install pymysql

import pymysql as psql

import pymysql as psql
#连接数据库
db=psql.connect(
    host='localhost', #这里是表示数据库地址
    user='heweijie',    #这里是表示用户名
    password='heweijie',    #这里是表示password
    database='hello',   #这里是表示要连接的数据库名字
    charset='utf8'      #这里是字符编码，一般都选utf8
)
#创建读取游标
cur=db.cursor()
sql=r'select version();' #sql语句，查看mysql版本
cur.execute(sql)      #执行sql语句
data=cur.fetchone()   #返回一条信息
print(data)
cur.close()     #关闭游标
db.close()      #关闭数据库的连接
#输出结果：('8.0.30',)
 

 
#创建读取游标
cur=db.cursor()
sql=r'select *from user' #sql语句，查看mysql版本
cur.execute(sql)      #执行sql语句
#返回一条信息
data1=cur.fetchone()
print('fecthone>>>',data1)
#返回自定义条数
data2=cur.fetchmany(5)
print('fetchmany>>>',data2)
#返回全部信息
data3=cur.fetchall()
print('fecthall>>>',data3)

import pymysql as psql
class Database:
    '''通过面对对象的方式去创建一个数据库以及
    实现数据库管理操作方法'''
    def __init__(self):
        self.db=psql.connect(
            host='localhost',
            user='heweijie',
            password='heweijie',
            charset='utf8'
        )
        #操作游标
        self.cur = self.db.cursor()
    def create(self,name):
        '''创建一个数据库,名字为name，自行输入'''
        try:
            sql=fr'create database if not exists {name}'
            self.cur.execute(sql)
        except Exception as e:
            print(e)
            print('创建失败')
            self.db.rollback() #事物的回滚操作，就是回到开始
    def showdatabases(self):
        '''查看全部数据库名字'''
        sql=r'show databases'
        self.cur.execute(sql)
        result=self.cur.fetchall()
        return result
    #删除数据库
    def dropdatabase(self,name):
        try:
            sql=fr'drop database {name}'
            self.cur.execute(sql)
        except Exception as e:
            print(e)
            print('删除失败')
            self.db.rollback()
    def close(self):
        '''关闭连接，结束操作'''
        self.cur.close()
        self.db.close()
#操作示例：
if __name__ == '__main__':  
    d=Database()
    d.create('fucc')
    print(d.showdatabases())
    d.dropdatabase('fucc')
    print(d.showdatabases())
    d.close()

def connect(database_name):
    db = psql.connect(
        host='127.0.0.1',
        user='heweijie',
        password='heweijie',
        port=3306,
        database=database_name,
        charset='utf8'
    )
    return db #返回当前连接的数据库
def createtable(name):
    db=connect('test') #数据库名字为test
    cur=db.cursor()
    try:
        sql=f'create table if not exists {name}(id int primary key auto_increment,name char(50),num int);'
        print('创建成功')
    except Exception as e:
        print(e)
        db.rollback()

#………………
def desctable(name): #表的名字为name
    db=connect('test')
    cur=db.cursor()
    sql=f'desc {name}'
    cur.execute(sql)
    print(cur.fetchall()) #输出全部结果

#…………
def showtables():
    db=connect('test')
    cur=db.cursor()
    sql='show tables;'
    cur.execute(sql)
    print(cur.fetchall())

#………………
def droptable(name):
    db = connect('test')
    cur = db.cursor()
    try:
        sql = f'drop table {name};'
        cur.execute(sql)
        print('删除成功')
    except Exception as e:
        print(e)
        db.rollback()

#创建表以及操作
class Table(object):
    def __init__(self,database_name):
        '''连接数据库database_name,自写'''
        self.db=psql.connect(
            host='127.0.0.1',
            user='heweijie',
            password='heweijie',
            port=3306,
            database=database_name,
            charset='utf8'
        )
        self.cur=self.db.cursor()
    def create(self,sql):
        '''创建表,sql语句自行写入'''
        try:
            self.cur.execute(sql)
            print('create successfully')
        except Exception as e:
            print(e)
            self.db.rollback()
    def desctable(self,table):
        '''查看表结构'''
        sql=fr'desc {table};'
        self.cur.execute(sql)
        result=self.cur.fetchall()
        print(result)
    def showtables(self):
        '''查看这个数据库里面的全部表'''
        sql=f'show tables;'
        self.cur.execute(sql)
        result=self.cur.fetchall()
        print(result)
    def droptable(self,name):
        '''把名字为name的表删除'''
        try:
            sql=f'drop table {name};'
            self.cur.execute(sql)
        except Exception as e:
            print(e)
            self.db.rollback()
    def insert(self,sql):
        '''插入数据，sql语句自写'''
        try:
            self.cur.execute(sql)
        except Exception as e:
            print(e)
            self.db.rollback()
    def selectdata(self,sql):
        '''查询数据，sql语句自写'''
        self.cur.execute(sql)
        result=self.cur.fetchall()
        print(result)
#使用示例
if __name__ == '__main__':
    user=Table('hello')
    user.create(r'create table if not exists mydatabase (id int primary key auto_increment,name char(50),num int);')
    user.showtables()
    user.desctable('mydatabase')
    user.selectdata('select *from user;')#user 是另外一个表
    user.droptable('mydatabase')
    user.showtables()