dify数据库的操作方式
- 基础环境安装
- 修改sanbox增加以来
- 代码执行
- 执行
基础环境安装
基础环境安装
修改sanbox增加以来
# 在线方式
# 修改volumes/sandbox/dependencies/python-requirements.txt
mysql-connector-python
# 离线方式
# 下载https://mirrors.aliyun.com/pypi/packages/81/80/5c3286fe2da2ca1a361483a2c20f17c77b543563f3a4fc8d7c18c07923a5/mysql_connector_python-9.2.0-cp310-cp310-manylinux_2_28_x86_64.whl
# 放到volumes/sandbox/dependencies目录下
/dependencies/mysql_connector_python-9.2.0-cp310-cp310-manylinux_2_28_x86_64.whl
代码执行
python">import uuid
import mysql.connector
from mysql.connector import Errordef main(leave_name: str, leave_cause: str, leave_days: int) -> dict:connection = Nonecursor = Nonetry:connection = mysql.connector.connect(host='192.168.3.230',user='root',password='xxx',database='dify_demo')# 准备插入语句sql = """INSERT INTO dify_ask_for_leave(id_, name_, days, cause)VALUES (%s, %s, %d, %s)"""rd_id = uuid.uuid4()str_id = str(rd_id)data = (str_id, leave_name, leave_days, leave_cause)# 执行插入操作 cursor = connection.cursor()cursor.execute(sql, data)# 提交事务connection.commit()print("数据插入成功！")except Error as e:print(f"数据库错误: {e}")connection.rollback() # 回滚事务finally:if connection:cursor.close()connection.close()return {"result": leave_name + ',' + leave_cause + ',' + str(leave_days)}
执行
