in springbootsample/src/main/java/andrew/ren/springbootsample/SampleController.java [78:101]
private String rdsTest() {
try {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(rds_driver);
dataSource.setUrl(rds_url);
dataSource.setUsername(rds_username);
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
jdbcTemplate.execute("CREATE DATABASE IF NOT EXISTS test");
StringBuilder sb = new StringBuilder();
sb.append("CREATE TABLE IF NOT EXISTS test.user (id int (10) unsigned NOT NULL AUTO_INCREMENT,\n")
.append("name varchar (64) NOT NULL DEFAULT '',\n")
.append("PRIMARY KEY (ID));\n");
jdbcTemplate.execute(sb.toString());
jdbcTemplate.update("REPLACE INTO test.user(id, name) VALUES(1, 'test')");
Integer count = jdbcTemplate.queryForObject("SELECT count(*) FROM test.user", Integer.class);
if (count == 1)
return "passed";
else
return "failed";
}catch(Exception e){
return "failed";
}
}