如何用Java连接Aurora MySQL

    xiaoxiao2022-07-04  120

    利用Java 访问Aurora

    以下是使用mysql-connector 连接Aurora for mysql参考示例 Workbench 访问Aurora,跟mysql方式一致,如: Aurora.example.rds.cn-northwest-1.amazonaws.com.cn 用户名:root 密码:root Eclipse 开发首先在maven添加依赖,如下:

    <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.15</version> </dependency>

    源代码:

    package Aurora.test; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class ConnectAurora { public static void main(String[] args) { // TODO Auto-generated method stub //声明Connection对象 Connection con; String driver = "com.mysql.cj.jdbc.Driver"; //URL指向要访问的数据库名mydata String url = "jdbc:mysql:// Aurora.example.rds.cn-northwest-1.amazonaws.com.cn:3306/db3"; //MySQL配置时的用户名 String user = "root"; //MySQL配置时的密码 String password = "root"; //遍历查询结果集 try { //加载驱动程序 Class.forName(driver); //1.getConnection()方法,连接MySQL数据库!! con = DriverManager.getConnection(url,user,password); if(!con.isClosed()) System.out.println("Succeeded connecting to the Database!"); //2.创建statement类对象,用来执行SQL语句!! Statement statement = con.createStatement(); //要执行的SQL语句 String sql = "select * from fileindex"; //3.ResultSet类,用来存放获取的结果集!! ResultSet rs = statement.executeQuery(sql); System.out.println("-----------------------------------------------------------------------------------------------"); System.out.println("------------------------------------------------------------------------------------------------"); System.out.println("| "+ "id" + " " +" | "+ "app_id"+ " " +" | "+ "文件名字"+ " " +" | " + "文件地址"+ " " +" | "); System.out.println("------------------------------------------------------------------------------------------------"); String APP_ID = null; String id = null; String address = null; String school = null; while(rs.next()){ //获取stuname这列数据 id = rs.getString("ID"); //获取stuid这列数据 APP_ID = rs.getString("APP_ID"); address= rs.getString("File_Name"); school=rs.getString("File_url"); //输出结果 System.out.println(" | "+id + " " +" | "+ APP_ID +" | "+ " " +" | "+address +" | "+ " " +" | "+school +" | " ); System.out.println(" ------------------------------------------------------------------"); } rs.close(); con.close(); } catch(ClassNotFoundException e) { //数据库驱动类异常处理 System.out.println("Sorry,can`t find the Driver!"); e.printStackTrace(); } catch(SQLException e) { //数据库连接失败异常处理 e.printStackTrace(); }catch (Exception e) { // TODO: handle exception e.printStackTrace(); }finally{ System.out.println("数据库数据成功获取!"); } } }

    Workbench 查询 Java 查询结果:

    最新回复(0)