SSH代理连接JDBC数据库

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用系列 2核4GB
简介: SSH代理连接JDBC数据库

依赖配置pom

<dependency>
    <groupId>com.jcraft</groupId>
    <artifactId>jsch</artifactId>
    <version>0.1.54</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.38</version>
</dependency>
AI 代码解读

创建代理会话

/**
 * 创建代理会话。会话使用结束后,别忘了调用closeSession以关闭会话。
 */
public static Session getSession(String sshIp, 
        String sshUser, 
        int sshPort, 
        String sshPwd, 
        String sshKeyPath) throws JSchException {
    JSch jSch = new JSch();
    if(sshKeyPath != null) jSch.addIdentity(sshKeyPath);
    Session sesion = jSch.getSession(sshUser, sshIp, sshPort);
    sesion.setPassword((sshPwd == null) ? "" : sshPwd);
    Properties config = new Properties();
    config.put("StrictHostKeyChecking", "no");
    sesion.setConfig(config);
    sesion.connect();
    return sesion;
}
AI 代码解读

创建本地代理端口

/**
 * 创建本地代理端口。
 */
public static int getPortForwardingL(Session sesion, 
        int loaclPort, 
        String mysqlIp, 
        int mysqlPort) throws JSchException {
    return sesion.setPortForwardingL(loaclPort, mysqlIp, mysqlPort);
}
AI 代码解读

创建数据库连接

/**
 * 创建数据库连接。
 */
public static Connection getConnection(String driver, 
        String localIp, 
        int portForwardingL, 
        String db, 
        String user, 
        String pwd) throws Exception {
    String mysqlUrl = "jdbc:mysql://" + localIp + ":" + portForwardingL + "/" + db + "?characterEncoding=utf8&useSSL=false"; 
    Class.forName(driver); 
    return DriverManager.getConnection(mysqlUrl, user, pwd);
}
AI 代码解读

调用示例代码

public static void main(String[] args) throws Exception {
    // 代理服务器信息
    String sshIp = "xxx.xxx.xxx.xxx";
    String sshUser = "user";
    int sshPort = 8585;
    String sshPwd = "";
    String sshKeyPath = "本地路径/id_rsa.rsa";
    
    // 本机基本设置
    int localPort = 12365; 
    String localIp = "localhost";
    
    // 数据库JDBC连接信息
    String mysqlIp = "xxx.xxx.xxx.xxx"; 
    int mysqlPort = 3306;
    String mysqlDriver = "com.mysql.jdbc.Driver";
    String mysqlUser = "user";
    String mysqlPwd = "pwd";
    String mysqlDB = "db";
    
    // 创建代理会话。会话使用结束后,别忘了调用closeSession以关闭会话。
    Session session = SsshJdbcUtils.getSession(sshIp, sshUser, sshPort, sshPwd, sshKeyPath);
    
    // 创建本地代理端口。
    int portForwardingL = SsshJdbcUtils.getPortForwardingL(session, localPort, mysqlIp, mysqlPort);
    
    // 创建数据库连接。
    Connection connection = SsshJdbcUtils.getConnection(mysqlDriver, localIp, portForwardingL, mysqlDB, mysqlUser, mysqlPwd);
    
    // 查询数据
    Statement statement = connection.createStatement();
    ResultSet resultSet = statement.executeQuery("show tables");
    if(resultSet != null) {
        while(resultSet.next()) {
            String tableName = resultSet.getString(1);
            System.err.println(tableName);
        }
    }
    
    // 关闭相关连接
    if(resultSet != null && !resultSet.isClosed()) resultSet.close();
    if(statement != null && !statement.isClosed()) statement.close();
    if(connection != null && !connection.isClosed()) connection.close();
    if(session != null && session.isConnected()) session.disconnect();
}
AI 代码解读
相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
打赏
0
1
0
0
52
分享
相关文章
如何排查和解决PHP连接数据库MYSQL失败写锁的问题
通过本文的介绍,您可以系统地了解如何排查和解决PHP连接MySQL数据库失败及写锁问题。通过检查配置、确保服务启动、调整防火墙设置和用户权限,以及识别和解决长时间运行的事务和死锁问题,可以有效地保障应用的稳定运行。
47 25
Unity连接Mysql数据库 增 删 改 查
在 Unity 中连接 MySQL 数据库,需使用 MySQL Connector/NET 作为数据库连接驱动,通过提供服务器地址、端口、用户名和密码等信息建立 TCP/IP 连接。代码示例展示了如何创建连接对象并执行增删改查操作,确保数据交互的实现。测试代码中,通过 `MySqlConnection` 类连接数据库,并使用 `MySqlCommand` 执行 SQL 语句,实现数据的查询、插入、删除和更新功能。
Java后端开发-使用springboot进行Mybatis连接数据库步骤
本文介绍了使用Java和IDEA进行数据库操作的详细步骤,涵盖从数据库准备到测试类编写及运行的全过程。主要内容包括: 1. **数据库准备**:创建数据库和表。 2. **查询数据库**:验证数据库是否可用。 3. **IDEA代码配置**:构建实体类并配置数据库连接。 4. **测试类编写**:编写并运行测试类以确保一切正常。
56 2
gbase 8a 数据库 安装8ampp 常见ssh报错问题
gbase 8a 数据库 安装8ampp 常见ssh报错问题
Linux下ODBC与 南大通用GBase 8s数据库的无缝连接配置指南
本文详细介绍在Linux系统下配置GBase 8s数据库ODBC的过程,涵盖环境变量设置、ODBC配置文件编辑及连接测试等步骤。首先配置数据库环境变量如GBASEDBTDIR、PATH等,接着修改odbcinst.ini和odbc.ini文件,指定驱动路径、数据库名称等信息,最后通过catalog.c工具或isql命令验证ODBC连接是否成功。
Windows下C# 通过ADO.NET方式连接南大通用GBase 8s数据库(上)
Windows下C# 通过ADO.NET方式连接南大通用GBase 8s数据库(上)

热门文章

最新文章

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等