trino写入mysql的实际例子

Trino是一个开源的列式SQL查询引擎，通常用于处理大规模数据仓库和在线分析处理（OLAP）场景。它与MySQL这样的关系型数据库可以配合使用，将查询结果写入MySQL。以下是一个简单的实际例子：

假设你有一个Trino集群，并有一个表`sales`存储在其中，你想把`sales`表的数据导出到MySQL的一个名为`daily_sales`的表中。首先，你需要在Trino中创建一个SELECT查询，选择你需要的数据，然后配置连接MySQL的插件，比如JDBC驱动。

CREATE TABLE external_mysql.daily_sales AS
SELECT sale_date, product_id, quantity, total_amount
FROM sales;

这里，`external_mysql.daily_sales`是一个新的视图，它会实时反映`sales`表中的数据。`AS`关键字用于创建一个表，并通过查询的结果来填充数据。

接下来，需要在Trino的配置文件中设置JDBC连接信息，包括URL、用户名和密码。然后运行一个任务来定期或者一次性执行这个查询并将结果写入MySQL。这通常是通过调度系统（如Airflow）或Trino的内置任务调度功能完成的。

{
  "query": {
    "language": "jdbc",
    "jdbc-url": "jdbc:mysql://<your-mysql-host>:<port>/<database>",
    "user": "<username>",
    "password": "<password>",
    "sql": "INSERT INTO daily_sales SELECT * FROM external_mysql.daily_sales"
  },
  "schedule": "0 0 * * *"  // 每天0点执行
}

执行这个任务后，每次都会将`sales`表的新数据同步到MySQL的`daily_sales`表。