in application-workloads/jenkins/jenkins-cicd-webapp/src/main/java/com/cvz/azure/DbAccess.java [47:85]
public void initDbIfNeed(Connection conn) throws Exception {
// check table existence
ResultSet rs = conn.getMetaData().getTables(null, null, "products", null);
if (rs.next()) {
// skip as table already exists
return;
}
try
{
Statement stmt = conn.createStatement();
// create table
String sqlSchema = "CREATE TABLE products (" +
" Id int(11) NOT NULL," +
" Title varchar(45) NOT NULL," +
" Category varchar(45) DEFAULT NULL," +
" Description varchar(500) DEFAULT NULL," +
" PRIMARY KEY (Id)" +
");";
stmt.executeUpdate(sqlSchema);
// initialize data
String sqlData = "INSERT INTO products VALUES(1, 'Lorem ipsum dolor sit amet', 'Nullam', 'Donec id nulla molestie tortor gravida venenatis eu non leo. Suspendisse eget ante non arcu elementum dictum.');";
stmt.executeUpdate(sqlData);
sqlData = "INSERT INTO products VALUES(2, 'Donec id nulla molestie tortor', 'Pellentesque', 'Suspendisse eget ante non arcu elementum dictum. Praesent sit amet est non tortor consequat imperdiet sed in risus.');";
stmt.executeUpdate(sqlData);
sqlData = "INSERT INTO products VALUES(3, 'Fusce aliquam orci id vehicula malesuada', 'Phasellus', 'Mauris id nisl diam. Pellentesque ut leo massa. Vivamus et enim eu enim facilisis tempor. Vestibulum ante ipsum primis in faucibus orci luctus et ultrices posuere cubilia Curae');";
stmt.executeUpdate(sqlData);
stmt.close();
}
catch (SQLException e)
{
throw new SQLException("Encountered an error when initialize the database.", e);
}
}