本文主要介绍Java程序如何连接RDS MySQL。
阿里云提醒您:
- 如果您对实例或数据有修改、变更等风险操作,务必注意实例的容灾、容错能力,确保数据安全。
- 如果您对实例(包括但不限于ECS、RDS)等进行配置与数据修改,建议提前创建快照或开启RDS日志备份等功能。
- 如果您在阿里云平台授权或者提交过登录账号、密码等安全信息,建议您及时修改。
若您要连接云数据库RDS MySQL版的测试程序,您可以选择以下任意一种方法:
说明:需要您使用正确的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();
}
}
}
}