全部产品

Java程序如何连接RDS MySQL

概述

本文主要介绍Java程序如何连接RDS MySQL。

详细信息

阿里云提醒您:

  • 如果您对实例或数据有修改、变更等风险操作,务必注意实例的容灾、容错能力,确保数据安全。
  • 如果您对实例(包括但不限于ECS、RDS)等进行配置与数据修改,建议提前创建快照或开启RDS日志备份等功能。
  • 如果您在阿里云平台授权或者提交过登录账号、密码等安全信息,建议您及时修改。

若您要连接云数据库RDS MySQL版的测试程序,您可以选择以下任意一种方法:

  • 通过阿里云SDK
    • 在使用Java开发RDS管理和连接时,您可以通过阿里云的SDK连接云数据库RDS MySQL版的测试程序。您需要先安装JDK1.7及以上版本,然后通过Maven安装阿里云的Java SDK。下载阿里云关系型数据库所对应的SDK,详情请参见阿里云开发工具包
  • 通过MySQL客户端
    • 您可以使用MySQL Connector连接云数据库MySQL版的测试程序。通过官方网站下载,将对应的Jar包引入到构建目录。
  • 通过代码
    • 您可以通过代码连接云数据库RDS MySQL版的测试程序,示例代码如下。
      import java.sql.Connection;
      import java.sql.DriverManager;
      import java.sql.ResultSet;
      import java.sql.SQLException;
      import java.sql.Statement;
      public class mysqlconnection {
      public static void main(String[] args) {
      Connection conn = null;
         String sql;
      // 此处为您的连接地址、端口、账号、密码等信息。
         String url = "jdbc:mysql://rdssoxxxxxxxxx.mysql.rds.aliyuncs.com:3306?zeroDateTimeBehavior=convertToNull&"
              + "user=michael&password=password&useUnicode=true&characterEncoding=UTF8";
         try {
            Class.forName("com.mysql.jdbc.Driver");          
            conn = DriverManager.getConnection(url);
            Statement stmt = conn.createStatement();
      //切换库。
            String sqlusedb="use test_5";
            int result1 = stmt.executeUpdate(sqlusedb);
      //创建表。
            sql = "create table teacher(NO char(20),name varchar(20),primary key(NO))";
            int result = stmt.executeUpdate(sql);
      //插入数据。
            if (result != -1) {
              sql = "insert into teacher(NO,name) values('2016001','wangsan')";
      result = stmt.executeUpdate(sql);
              sql = "insert into teacher(NO,name) values('2016002','zhaosi')";
              result = stmt.executeUpdate(sql);
      //查询数据。
              sql = "select * from teacher";
              ResultSet rs = stmt.executeQuery(sql);
              System.out.println("学号\t姓名");
              while (rs.next()) {
                  System.out
                       .println(rs.getString(1) + "\t" + rs.getString(2));
              }
             }
      //捕捉异常。
          } catch (SQLException e) {
              System.out.println("MySQL操作错误");
              e.printStackTrace();
          } catch (Exception e) {
              e.printStackTrace();
          } finally {
              try {
      conn.close();
      } catch (SQLException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
      }
        }
      }
      }

适用于

  • 云数据库RDS MySQL版