5033b5f97e
- Add mymath.py with multiply and divide functions - Add SmartVoyage travel assistant project - Add .gitignore for Python cache files Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
35 lines
1.3 KiB
Python
35 lines
1.3 KiB
Python
import mysql.connector
|
||
import json
|
||
from datetime import datetime,date,timedelta
|
||
from decimal import Decimal
|
||
from mcp.server.fastmcp import FastMCP
|
||
from SmartVoyage.config import Config
|
||
from SmartVoyage.create_logger import logger
|
||
from SmartVoyage.utils.format import DateEncoder,default_encoder
|
||
|
||
config=Config()
|
||
|
||
#票务服务
|
||
class TicketService:#定义票务服务类，封装数据库操作逻辑
|
||
def __init__(self):#初始化方法，建立数据库连接
|
||
#连接数据库
|
||
self.conn=mysql.connector.connect(
|
||
host=config.host,
|
||
user=config.user,
|
||
password=config.password,
|
||
database=config.database
|
||
)
|
||
#定义执行sql查询方法，输入SQL字符串，返回JSON字符串
|
||
def execute_query(self,sql:str) -> str:
|
||
try:
|
||
cursor=self.conn.cursor(dictionary=True)
|
||
cursor.execute(sql)
|
||
resultes=cursor.fetchall()
|
||
cursor.close()
|
||
#格式化结果
|
||
for resulte in resultes:#遍历每个结果字典
|
||
for key,value in resulte.items():
|
||
if isinstance(value,(date,datetime,timedelta,Decimal)):#检查值是否是特殊类型
|
||
resulte[key]=default_encoder(value)#使用自定义编码器格式化该值
|
||
|