# 1. 下载Trino
cd /bigdata/app
wget https://repo1.maven.org/maven2/io/trino/trino-server/426/trino-server-426.tar.gz
tar -zxvf trino-server-426.tar.gz
ln -s trino-server-426 trino

# 2. 创建配置目录
mkdir -p /bigdata/app/trino/etc
mkdir -p /bigdata/app/trino/etc/catalog

# 3. 配置config.properties
cat > /bigdata/app/trino/etc/config.properties << ‘EOF’
coordinator=true
node-scheduler.include-coordinator=false
http-server.http.port=8080
query.max-memory=50GB
query.max-memory-per-node=10GB
discovery-server.enabled=true
discovery.uri=http://fgedu-trino-coordinator:8080
EOF

# 4. 配置jvm.config
cat > /bigdata/app/trino/etc/jvm.config << ‘EOF’
-server
-Xmx50G
-Xms50G
-XX:+UseG1GC
-XX:G1HeapRegionSize=32M
-XX:+UseGCOverheadLimit
-XX:+ExplicitGCInvokesConcurrent
-XX:+HeapDumpOnOutOfMemoryError
-XX:+ExitOnOutOfMemoryError
-XX:HeapDumpPath=/bigdata/fgdata/trino/heapdump
-XX:+PrintGCDetails
-XX:+PrintGCDateStamps
-Xloggc:/bigdata/fgdata/logs/trino/gc.log
EOF

# 5. 配置node.properties
cat > /bigdata/app/trino/etc/node.properties << ‘EOF’
node.environment=production
node.id=fgedu-trino-coordinator-01
node.data-dir=/bigdata/fgdata/trino
EOF

# 6. 配置Hive连接器
cat > /bigdata/app/trino/etc/catalog/hive.properties << ‘EOF’
connector.name=hive
hive.metastore.uri=thrift://fgedu-hive-metastore:9083
hive.config.resources=/bigdata/app/hadoop/etc/hadoop/core-site.xml,/bigdata/app/hadoop/etc/hadoop/hdfs-site.xml
EOF

# 7. 配置MySQL连接器（Doris）
cat > /bigdata/app/trino/etc/catalog/doris.properties << ‘EOF’
connector.name=mysql
connection-url=jdbc:mysql://fgedu-doris:9030
connection-user=root
connection-password=
EOF

# 8. 配置ClickHouse连接器
cat > /bigdata/app/trino/etc/catalog/clickhouse.properties << ‘EOF’
connector.name=clickhouse
connection-url=jdbc:clickhouse://fgedu-clickhouse:8123
connection-user=default
connection-password=
EOF

# 9. 启动Trino
/bigdata/app/trino/bin/launcher start

# 10. 验证安装
/bigdata/app/trino/bin/trino –server localhost:8080
trino> SHOW CATALOGS;

# 使用Trino的Session属性路由
# 连接时指定Catalog
trino –server fgedu-trino:8080 –catalog hive –schema default

# 或者在SQL中指定
SELECT * FROM hive.default.fgedu_user;
SELECT * FROM doris.fgedu_db.fgedu_user;
SELECT * FROM clickhouse.fgedu_db.fgedu_user;

# 创建视图统一查询
CREATE VIEW unified_fgedu_user AS
SELECT * FROM hive.default.fgedu_user
UNION ALL
SELECT * FROM doris.fgedu_db.fgedu_user;

# 自定义路由应用（示例）
@RestController
@RequestMapping(“/api/v1/query”)
public class QueryController {

@PostMapping
public ResponseEntity<QueryResult> executeQuery(@RequestBody QueryRequest request) {
String sql = request.getSql();
QueryEngine engine = selectEngine(sql);
QueryResult result = executeWithEngine(sql, engine);
return ResponseEntity.ok(result);
}

private QueryEngine selectEngine(String sql) {
// 解析SQL，估算数据量
Estimation estimation = estimateQuery(sql);

if (estimation.getDataSizeGB() < 100) {
return QueryEngine.DORIS;
} else if (estimation.getDataSizeGB() < 1000) {
return QueryEngine.PRESTO;
} else {
return QueryEngine.HIVE;
}
}
}

# Trino LDAP认证
etc/config.properties:
http-server.authentication.type=PASSWORD

etc/password-authenticator.properties:
password-authenticator.name=ldap
ldap.url=ldap://fgedu-ldap:389
ldap.user-bind-pattern=uid=${USER},ou=users,dc=fgedu,dc=net,dc=cn
ldap.user-base-dn=ou=users,dc=fgedu,dc=net,dc=cn

# Trino Ranger授权
etc/config.properties:
access-control.config-file=etc/access-control.properties

etc/access-control.properties:
access-control.name=ranger
ranger.policy.rest.url=http://fgedu-ranger:6080
ranger.service.name=trino
ranger.plugin.config.directory=/bigdata/app/trino/etc/ranger

# 自定义认证
@Component
public class AuthFilter implements GlobalFilter {

@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
String token = exchange.getRequest().getHeaders().getFirst(“Authorization”);
if (token == null || !validateToken(token)) {
exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
return exchange.getResponse().setComplete();
}

User user = getUserFromToken(token);
if (!hasPermission(user, exchange.getRequest())) {
exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);
return exchange.getResponse().setComplete();
}

return chain.filter(exchange);
}
}