数据集来自https://github.com/xuchunyang/300/blob/master/300.json
将数据导入MySQL数据库持久化 这里可以使用我提供的Python脚本
from ctypes import sizeof
import pymysql
import json
class MysqlDb():
def __init__(self, host, port, user, passwd, db):
# 建立数据库连接
self.conn = pymysql.connect(
host=host,
port=port,
user=user,
passwd=passwd,
db=db,
autocommit=True
)
# 通过 cursor() 创建游标对象，并让查询结果以字典格式输出
self.cur = self.conn.cursor(cursor=pymysql.cursors.DictCursor)
def __del__(self): # 对象资源被释放时触发，在对象即将被删除时的最后操作
# 关闭游标
self.cur.close()
# 关闭数据库连接
self.conn.close()
def select_db(self, sql):
"""查询"""
# 检查连接是否断开，如果断开就进行重连
self.conn.ping(reconnect=True)
# 使用 execute() 执行sql
self.cur.execute(sql)
# 使用 fetchall() 获取查询结果
data = self.cur.fetchall()
return data
def execute_db(self, sql):
"""更新/新增/删除"""
try:
# 检查连接是否断开，如果断开就进行重连
self.conn.ping(reconnect=True)
# 使用 execute() 执行sql
self.cur.execute(sql)
# 提交事务
self.conn.commit()
except Exception as e:
print("操作出现错误：{}".format(e))
# 回滚所有更改
self.conn.rollback()
MYSQL_HOST = '127.0.0.1'
MYSQL_PORT = 3306
MYSQL_USER = 'root'
MYSQL_PASSWD = '123456'
MYSQL_DB = 'poem'
db = MysqlDb(MYSQL_HOST, MYSQL_PORT, MYSQL_USER, MYSQL_PASSWD, MYSQL_DB)
def read_and_write():
input_file = open('poem.json', encoding="utf8", errors='ignore')
poem_list = json.load(input_file)
for poem in poem_list:
sql = "insert into poem values ('{}','{}','{}','{}','{}')".format(
poem['id']
,poem['contents']
,poem['type']
,poem['author']
,poem['title'])
db.execute_db(sql)
if __name__ == '__main__':
read_and_write()通过/poem/importAll接口将MySQL数据载入Elasticsearch
通过/poem/search接口模糊搜索
浏览器访问，可视化搜索
