【trino权威指南】使用trino详解：trino client安装、查询sql、DBeaver连接trino、java通过JDBC连接trino_数据分析

您的位置：上海毫米网络优化公司 > 业务范围 > 数据分析 >

文章目录

一. Trino CLI

1. 安装client
2. 使用client执行sql
二. JDBC driver 连接Trino

1. 通过DBeaver用户界面连接
2. JDBC Driver in java
2.1. 环境配置
2.2. 注册和配置driver
2.3. 连接参数

2.4. 查询例子

一. Trino CLI

1. 安装client

Trino CLI提供了一个基于终端的交互式shell。你可以通过它运行查询并与Trino服务端交互来检查其元数据。

下载地址：trino-cli-434-executable.jar

# 下载
 wget -O trino https://repo1.maven.org/maven2/io/trino/trino-cli/434/trino-cli-434-executable.jar
# 添加可执行权限、并将其添加到PATH下，方便使用
chmod +x trino
mv trino ~/bin
export PATH=~/bin/:$PATH

2. 使用client执行sql

./trino http://trino.example.com:8080
# 帮助文档
trino> help
Supported commands:
QUIT
EXIT
CLEAR
EXPLAIN [ ( option [, ...] ) ] 
    options: FORMAT { TEXT | GRAPHVIZ | JSON }
            TYPE { LOGICAL | DISTRIBUTED | VALIDATE | IO }
DESCRIBE 
SHOW COLUMNS FROM 
SHOW FUNCTIONS
SHOW CATALOGS [LIKE ]
SHOW SCHEMAS [FROM ] [LIKE ]
SHOW TABLES [FROM ] [LIKE ]
USE [.]
 
 
运行sql 
trino> select *  from "mysql-1".flinkx_test.flinkx_hdfs_log
    -> ;
  id  |       ip        | stamp | url  | refer | useragent |   pid    | uid  | mid  |     insert_time     | create_time | create_date
------+-----------------+-------+------+-------+-----------+----------+------+------+---------------------+-------------+-------------
    1 | NULL            | NULL  | NULL | aaaa  | NULL      | 20221212 | NULL | NULL | 2023-01-31 16:32:09 | NULL        | 2023-01-11
    1 | NULL            | NULL  | NULL | aaaa  | NULL      | 20221212 | NULL | NULL | 2023-01-31 18:37:20 | NULL        | 2023-01-11  
...
(18 rows)
Query 20231206_032803_00000_78prf, FINISHED, 1 node
Splits: 1 total, 1 done (100.00%)
0.67 [18 rows, 0B] [26 rows/s, 0B/s]
 
 
连接trino时可以设置默认的catalog（某个连接实例）和schema（数据库），这样可以直接查询表。 
 ./trino http://localhost:8080/mysql-1/flinkx_test
trino:flinkx_test> show tables;
                        Table
-----------------------------------------------------
 aaa
 aaa_csv111_1
 aaa_csv111_2     
...
 
  
USE默认的catalog和schema，直接查询此库下的表 
trino> USE tpch.tiny;
USE
trino:tiny>
 
  
debug功能 
./trino http://localhost:8080/mysql-1/flinkx_test --debug 
trino:flinkx_test> select *  from "mysql-1".flinkx_test.flinkx_hdfs_log
                -> ;
  id  |       ip        | stamp | url  | refer | useragent |   pid    | uid  | mid  |     insert_time     | create_time | create_date
------+-----------------+-------+------+-------+-----------+----------+------+------+---------------------+-------------+-------------
    1 | NULL            | NULL  | NULL | aaaa  | NULL      | 20221212 | NULL | NULL | 2023-01-31 16:32:09 | NULL        | 2023-01-11
    1 | NULL            | NULL  | NULL | aaaa  | NULL      | 20221212 | NULL | NULL | 2023-01-31 18:37:20 | NULL        | 2023-01-11  
...
http://localhost:8080/ui/query.html?20231206_033726_00007_78prf
Splits: 1 total, 1 done (100.00%)
CPU Time: 0.0s total,    3K rows/s,     0B/s, 4% active
Per Node: 0.0 parallelism,    30 rows/s,     0B/s
Parallelism: 0.0
Peak Memory: 64B
0.60 [18 rows, 0B] [30 rows/s, 0B/s]
 
 
--execute选项 
 ./trino http://localhost:8080/mysql-1/flinkx_test --execute 'select *  from "mysql-1".flinkx_test.flinkx_hdfs_log limit 3;'
 
"1","","","","aaaa","","20221212","","","2023-01-31 16:32:09","","2023-01-11"
"1","","","","aaaa","","20221212","","","2023-01-31 18:37:20","","2023-01-11"
"","124.239.193.194","","","","","h_home","","","2023-02-10 10:52:01","",""
 
  
避免使用完全限定符 
# 使用`--catalog`和`--schema`选项来
./trino http://localhost:8080 --catalog "mysql-1" --schema flinkx_test \
	--execute 'select *  from flinkx_hdfs_log limit 3;'
# 通过http设限定符
./trino http://localhost:8080/mysql-1/flinkx_test  \
	--execute 'select *  from flinkx_hdfs_log limit 3;'
 
 
执行多个sql 
trino http://localhost:8080  \
	--execute 'use "mysql-1".flinkx_test;select *  from flinkx_hdfs_log limit 3;'
 
 
执行sql文件 
vim trino.sql
use "mysql-1".flinkx_test;
select *  from flinkx_hdfs_log limit 3;
./trino http://localhost:8080  -f trino.sql
 
 
输出格式 
 
 Trino CLI提供了--output-format选项来控制如何在非交互模式下显示输出，可用的选项有ALIGNED、VERTICAL、TSV、TSV_HEADER、CSV、CSV_HEADER、CSV_UNQUOTED、CSV_HEADER_UNQUOTED、JSON和NULL，默认值是CSV。 
 
 
忽略错误 
 
 Trino CLI提供了--ignore-error选项来忽略执行文件中的查询时遇到的任何错误。默认行为是在遇到第一个错误时终止执行脚本。 
 
  
二. JDBC driver 连接Trino 
任何Java应用程序都可以通过Java数据库连接(JDBC)驱动连接到Trino。通过JDBC驱动，所有这些应用程序都可以使用Trino。 
Trino的JDBC驱动允许你连接到Trino并使用SQL语句与Trino交互。 
如果你熟悉JDBC驱动的不同实现，就知道Trino的JDBC驱动是Type 4驱动，这仅仅意味着它直接与Trino原生协议通信。 
  
1. 通过DBeaver用户界面连接 
 
查看表时出现如下错误：
 
需要声明用户，默认输入admin、密码为空
 
重新连接可以看到注册的catalog了
可以像之前使用DBeaver查看表了。 
  
2. JDBC Driver in java 
2.1. 环境配置 
 
 需要java 8 或更高
所有通过JDBC连接Trino的用户，必须在system.jdbc schema中赋予权限 
 
maven依赖： 

    io.trino
    trino-jdbc
    434

 
其他版本地址在： 
 
 A list of all available versions can be found in the Maven Central Repository. 
 
客户端使用http协议和 Trino client REST API 和Trino进行通讯。 
  
2.2. 注册和配置driver 
JDBC URL支持的格式： 
jdbc:trino://host:port
jdbc:trino://host:port/catalog
jdbc:trino://host:port/catalog/schema
 
举例： 
jdbc:trino://example.net:8080/hive/sales
 
连接example.net上的trino（8080端口），并明确了catalog和schema。 
 
 如果trino的驱动识别不到，则可以显式声明：io.trino.jdbc.TrinoDriver。 
 
  
2.3. 连接参数 
声明方式有如下两种 
// properties
String url = "jdbc:trino://example.net:8080/hive/sales";
Properties properties = new Properties();
properties.setProperty("user", "test");
properties.setProperty("password", "secret");
properties.setProperty("SSL", "true");
Connection connection = DriverManager.getConnection(url, properties);
// URL parameters
String url = "jdbc:trino://example.net:8443/hive/sales?user=test&password=secret&SSL=true";
Connection connection = DriverManager.getConnection(url);
 
当然这两种方式我们可以混用，有些参数通过properties设置，有些在url中设置。 
 
 完整的参数见：Parameter reference 
 
  
2.4. 查询例子 
package com.gao;
import java.sql.*;
public class TrinoQueryExample {
    public static void main(String[] args) {
        // Trino数据库连接信息
        String trinoUrl = "jdbc:trino://xxx:8080";
        String trinoUser = "admin";
        String trinoPassword = "";
        // SQL查询语句
        String sqlQuery = "select *  from  \"mysql-1\".flinkx_test.flinkx_hdfs_log limit 3";
        try {
            Class.forName("io.trino.jdbc.TrinoDriver");
            // 建立Trino数据库连接
            Connection connection = DriverManager.getConnection(trinoUrl, trinoUser, trinoPassword);
            // 创建Statement对象
            Statement statement = connection.createStatement();
            // 执行查询
            ResultSet resultSet = statement.executeQuery(sqlQuery);
            // 处理查询结果
            while (resultSet.next()) {
                // 根据查询结果的列名或索引获取数据
                Integer id = resultSet.getInt("id");
                Timestamp create_time = resultSet.getTimestamp("create_time");
                // 处理获取的数据
                System.out.println("id: " + id + ", create_time: " + create_time);
            }
            // 关闭资源
            resultSet.close();
            statement.close();
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        }
    }
}

id: 1, create_time: null
id: 1, create_time: null
id: 0, create_time: null
 
 
 
参考：
《trino权威指南：原书第二版》
trino官网：https://trino.io/docs/current/client.html
  做个网站大概需要多少钱  网页设计创意  上海网站设计松一设计网站  seo关键词优化工具  如何免费建立一个网站  镇江网页设计 
 上一篇：爬虫 — App 爬虫（一）
 下一篇：Nginx修改文件上传大小
网站优化运营
 整站seo优化
 网络营销运营
 
成功案例
 品牌创意网站
 营销型网站
 
小程序
 微信小程序
 微信公众号
 百度熊掌号
 
网站优化分享
 
关于我们
 公司概况
 公司新闻
 公司文化
 结构体系
 企业资质
 加入我们
 
关注我们
扫描二维码
获取更多信息
精彩一手掌握
Copyright © 2014-2019 seo,上海网站优化_网络制作_网站seo排名_网站建设推广_上海网络公司 版权所有
沪ICP备19022315号 
在线咨询
QQ咨询
021-80394720
联系我们
返回顶部