python操作数据库access(python操作数据库定时删除数据)

首先导入相关库，import pymysql，安装搜其他教程。

首先定义一个发送指令函数，并且输出返回结果。

#发送指令
def db_send(s):
    cursor.execute(s)
    print(cursor.fetchall())

接下来定义创建数据库的函数，输入创建的数据库的名字即可。

#创建数据库
def db_create(s):
    s = "create database " + s + " default charset utf8 collate utf8_general_ci"
    cursor.execute(s)
    conn.commit()

还需要进入数据库并查看表的操作。

#进入数据库并查看表
def db_goto(s):
    s = "use " + s
    cursor.execute(s)
    db_send("show tables")

最后定义一个删除数据库的函数，同样输入删除的数据库名字即可。

#删除数据库
def db_del(s):
    s = "drop database " + s
    cursor.execute(s)
    conn.commit()

让我们来看一下整个代码的效果

import pymysql


#发送指令
def db_send(s):
    cursor.execute(s)
    print(cursor.fetchall())


#创建数据库
def db_create(s):
    s = "create database " + s + " default charset utf8 collate utf8_general_ci"
    cursor.execute(s)
    conn.commit()


#进入数据库并查看表
def db_goto(s):
    s = "use " + s
    cursor.execute(s)
    db_send("show tables")


#删除数据库
def db_del(s):
    s = "drop database " + s
    cursor.execute(s)
    conn.commit()


if __name__ == '__main__':
    #连接数据库
    conn = pymysql.connect(host='127.0.0.1', port=3306, user='root', password='root')
    cursor = conn.cursor()

    db_send("show databases")       #查看所有数据库

    db_create("db1")                #创建一个名叫db1的数据库，并显示所有数据库
    db_send("show databases")

    db_del("db1")                   #删除一个名叫db1的数据库，并显示所有数据库
    db_send("show databases")

    db_goto("mysql")                #进入mysql数据库，并查看表

    cursor.close()
    conn.close()
    

输出结果如下图：

D:Appsanacondapython.exe D:/Zimo/Desktop/python_mysql/example/pymysql_1.py
(('day',), ('information_schema',), ('mysql',), ('performance_schema',), ('sys',))
(('day',), ('db1',), ('information_schema',), ('mysql',), ('performance_schema',), ('sys',))
(('day',), ('information_schema',), ('mysql',), ('performance_schema',), ('sys',))
(('columns_priv',), ('component',), ('db',), ('default_roles',), ('engine_cost',), ('func',), ('general_log',), ('global_grants',), ('gtid_executed',), ('help_category',), ('help_keyword',), ('help_relation',), ('help_topic',), ('innodb_index_stats',), ('innodb_table_stats',), ('password_history',), ('plugin',), ('procs_priv',), ('proxies_priv',), ('replication_asynchronous_connection_failover',), ('replication_asynchronous_connection_failover_managed',), ('replication_group_configuration_version',), ('replication_group_member_actions',), ('role_edges',), ('server_cost',), ('servers',), ('slave_master_info',), ('slave_relay_log_info',), ('slave_worker_info',), ('slow_log',), ('tables_priv',), ('time_zone',), ('time_zone_leap_second',), ('time_zone_name',), ('time_zone_transition',), ('time_zone_transition_type',), ('user',))

Process finished with exit code 0

当然，创建重复文件，或者删除不存在文件会报错，后面文章会有说明以及解决办法。