关于常用mysql的文件

这个一般在做项目的时候会用到,直接建立函数啥的,后部直接调用

代码:

class_database.py

import pymysql

SERVER_HOST = "192.168.1.1"
SERVER_PORT = 3306
SERVER_DB = "数据库的名字,不是表的名字"
SERVER_USER = "root"
SERVER_PASS = "123456"

class DataBase:
def __init__(self):
self.conn = pymysql.connect(host=SERVER_HOST, port=SERVER_PORT, user=SERVER_USER, password=SERVER_PASS, database=SERVER_DB, charset='utf8')

def create_表名(self):
cursor = self.conn.cursor()
sql = """create table `表名` (
`date` varchar(100) COMMENT '日期'
) DEFAULT CHARSET=utf8;""" #注意,这个地方创建表时要加上,不然可能会出现中文乱码
cursor.execute(sql)
cursor.close()
self.conn.commit()
  # 断开数据库
  def close_mysql(self):
   self.conn.close()
  #插入数据
  def insertTB(self, sql):
  cursor = self.conn.cursor()
  cursor.execute(sql)
  cursor.close()
  self.conn.commit()
  #批量数据插入
  def many_insertTB(self, sql, datas):
  cursor = self.conn.cursor()
  cursor.executemany(sql, datas)
  cursor.close()
  self.conn.commit()
  #查询数据
  def selectTB(self, sql):
  cursor = self.conn.cursor()
  cursor.execute(sql)
  search_list = cursor.fetchall()
  cursor.close()
  self.conn.commit()
  return search_list
  #删除数据表
  def deleteTB(self, “表名”):
  cursor = self.conn.cursor()
   sql = "drop table %s;" % table_name
  cursor.execute(sql)
   cursor.close()
   self.conn.commit()

别的文件调用:
import class_database
database = class_database.DataBase()
result = database.select('select *from 表名')
database.close_mysql()

如果有可能,最好的话是学习一下mysql的触发器和存储过程,这个有利于数据库操作。










原文地址:https://www.cnblogs.com/wozuilang-mdzz/p/10736255.html