本文主要介绍Java程序如何连接RDS MySQL。
阿里云提醒您:
- 如果您对实例或数据有修改、变更等风险操作,务必注意实例的容灾、容错能力,确保数据安全。
- 如果您对实例(包括但不限于ECS、RDS)等进行配置与数据修改,建议提前创建快照或开启RDS日志备份等功能。
- 如果您在阿里云平台授权或者提交过登录账号、密码等安全信息,建议您及时修改。
若您要连接云数据库RDS MySQL版的测试程序,您可以选择以下任意一种方法:
说明:需要您使用正确的MySQL驱动。
1 | import java.sql.Connection;<br> import java.sql.DriverManager;<br> import java.sql.ResultSet;<br> import java.sql.SQLException;<br> import java.sql.Statement;<br> public class mysqlconnection {<br> public static void main(String[] args) {<br>Connection conn = null ;<br> String sql;<br> // 此处为您的连接地址、端口、账号、密码等信息。<br> String url = "jdbc:mysql://rdssoxxxxxxxxx.mysql.rds.aliyuncs.com:3306?zeroDateTimeBehavior=convertToNull&"<br> + "user=michael&password=password&useUnicode=true&characterEncoding=UTF8";<br> try {<br> Class.forName("com.mysql.jdbc.Driver"); <br> conn = DriverManager.getConnection(url);<br> Statement stmt = conn.createStatement();<br> //切换库。<br> String sqlusedb="use test_5";<br> int result1 = stmt.executeUpdate(sqlusedb);<br> //创建表。<br> sql = "create table teacher(NO char(20),name varchar(20),primary key(NO))";<br> int result = stmt.executeUpdate(sql);<br> //插入数据。<br> if (result != -1) {<br> sql = "insert into teacher(NO,name) values('2016001','wangsan')";<br> result = stmt.executeUpdate(sql);<br> sql = "insert into teacher(NO,name) values('2016002','zhaosi')";<br> result = stmt.executeUpdate(sql);<br> //查询数据。<br> sql = "select * from teacher";<br> ResultSet rs = stmt.executeQuery(sql);<br> System.out.println("学号\t姓名");<br> while (rs.next()) {<br> System.out<br> .println(rs.getString(1) + "\t" + rs.getString(2));<br> }<br> }<br> //捕捉异常。<br> } catch (SQLException e) {<br> System.out.println("MySQL操作错误");<br> e.printStackTrace();<br> } catch (Exception e) {<br> e.printStackTrace();<br> } finally {<br> try {<br>conn.close();<br>} catch (SQLException e) {<br>// TODO Auto-generated catch block<br>e.printStackTrace();<br>}<br> }<br>}<br>} |