连接数据库

3.1 连接数据库

@Keyword

def connectDBcatc(){

//Load driver class for your specific database type

//String conn = "jdbc:oracle:thin:@" + host + ":" + port + ":" + sid

String conn = "jdbc:oracle:thin:@111.11.111.11:1111:orcl"

String usernameofcata = "PIM_PICL_CATC"

String passwordofcata = "PIM_PICL_CATC"

if(connection != null && !connection.isClosed()){

connection.close()

}

connection = DriverManager.getConnection(conn, usernameofcata, passwordofcata)

return connection

}

3.2 执行SQL 语句

/**

* execute a SQL query on database

* @param queryString SQL query string

* @return a reference to returned data collection, an instance of java.sql.ResultSet

*/

//Executing the constructed Query and Saving results in resultset

@Keyword

def executeQuery(String queryString) {

Statement stm = connection.createStatement()

ResultSet rs = stm.executeQuery(queryString)

return rs

}

3.3 关闭连接

//Closing the connection

@Keyword

def closeDatabaseConnection() {

if(connection != null && !connection.isClosed()){

connection.close()

}

connection = null

}