📄 dbutils.java
字号:
/*
* Copyright (c) 2006, University of Kent
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* Redistributions of source code must retain the above copyright notice, this
* list of conditions and the following disclaimer.
*
* Redistributions in binary form must reproduce the above copyright notice,
* this list of conditions and the following disclaimer in the documentation
* and/or other materials provided with the distribution.
*
* 1. Neither the name of the University of Kent nor the names of its
* contributors may be used to endorse or promote products derived from this
* software without specific prior written permission.
*
* 2. THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
* IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
* THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
* PURPOSE ARE DISCLAIMED.
*
* 3. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*
* 4. YOU AGREE THAT THE EXCLUSIONS IN PARAGRAPHS 2 AND 3 ABOVE ARE REASONABLE
* IN THE CIRCUMSTANCES. IN PARTICULAR, YOU ACKNOWLEDGE (1) THAT THIS
* SOFTWARE HAS BEEN MADE AVAILABLE TO YOU FREE OF CHARGE, (2) THAT THIS
* SOFTWARE IS NOT "PRODUCT" QUALITY, BUT HAS BEEN PRODUCED BY A RESEARCH
* GROUP WHO DESIRE TO MAKE THIS SOFTWARE FREELY AVAILABLE TO PEOPLE WHO WISH
* TO USE IT, AND (3) THAT BECAUSE THIS SOFTWARE IS NOT OF "PRODUCT" QUALITY
* IT IS INEVITABLE THAT THERE WILL BE BUGS AND ERRORS, AND POSSIBLY MORE
* SERIOUS FAULTS, IN THIS SOFTWARE.
*
* 5. This license is governed, except to the extent that local laws
* necessarily apply, by the laws of England and Wales.
*/
/*
* Created on 14-Apr-2005
*
* TODO All
*/
package uk.ac.kent.dpa.mysql.init;
import ke.files.*;
import java.io.*;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;
import ke.defaultimpl.utils.*;
/**
* @author james Linying Su
*
* @version
*
* TODO All
*/
public class DbUtils
{
public DbUtils() {
}
//insert a record in CADTable, which represents a coordination attribute
public void insertRecord(String name,String defining,String list,
String value,Statement stmt,
Connection connection,DbConnectionPool pool) throws DatabaseException {
ResultSet sqlResults, sqlResult1;
RandomGUID myGUID = new RandomGUID();
String id = myGUID.toString();
id = "C"+id.replaceAll("-","x");
String sql = null;
boolean flag = true;
while (flag) {
sql = "SELECT CADTable.Id FROM CADTable WHERE Id='"+id+"';";
try {
sqlResults = stmt.executeQuery(sql);
if (!sqlResults.first()) {
flag = false;
sql = "SELECT CADTable.Id FROM CADTable WHERE Name='"+name+"' AND ";
sql += "AttributeDefinition='"+defining+"' AND ";
sql += "ListOfPolicies='"+list+"' AND ";
sql += "Value='"+value+"';";
sqlResult1 = stmt.executeQuery(sql);
if (!sqlResult1.first()) {
sql = "INSERT INTO CADTable (Name, Id, AttributeDefinition, ListOfPolicies, Value) ";
sql += "VALUES ('" + name + "', '" + id + "', '"+ defining + "', '" + list + "', '" + value + "');";
stmt.executeUpdate(sql);
}
break;
} else {
myGUID = new RandomGUID();
id = myGUID.toString();
id = "C"+id.replaceAll("-","x");
}
connection.rollback();
} catch (SQLException se) {
try{stmt.close();} catch (Exception e){};
try{connection.setAutoCommit(true);} catch (Exception e){};
try{pool.releaseConnection(connection);} catch (Exception e){};
throw new DatabaseException("Error:"+se);
}
}
}
public void createDbTables(Statement stmt, Connection connection,DbConnectionPool pool,String tableName) throws DatabaseException {
String sql;
sql = "create table "+tableName+" (";
sql += "Name text, ";
sql += "Id char(38), ";
sql += "AttributeDefinition text, ";
sql += "ListOfPolicies text, ";
sql += "Value text";
sql += ");";
try {
stmt.executeUpdate(sql);
} catch(SQLException sqle) {
throw new DatabaseException("Warnning: couldn't create coordination attribute distribution table: the error was: " + sqle);
}
}
public Properties getDbProperties(String fileName) throws DatabaseException {
try {
Properties props = new Properties();
InputStream in = new FileInputStream(fileName);
props.load(in);
in.close();
return props;
} catch (IOException ioe) {
throw new DatabaseException("Error reading database properties file: " + ioe);
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -