自己搭的WEB项目简易流程源码

package jp.co.greenblue.ecodasweb.dao; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import jp.co.greenblue.ecodasweb.dao.impl.DBUtilImpl; import jp.co.greenblue.ecodasweb.util.JavaSqlTypeConverter; public abstract class BaseDao { // Sql文 private String sqlString = null; // データベースの接続 private Connection connection = null; protected ResultSet resultSet=null; private PreparedStatement preparedStatement = null; // prepared statement parameters private Map<Integer, Object> parameters = new HashMap<Integer, Object>(); private Map<Integer, Integer> outParameters = new HashMap<Integer, Integer>(); public void openConnect()throws SQLException{ DBUtil dbUtil=new DBUtilImpl(); this.connection=dbUtil.getConnection(); } public void closeConnect() throws SQLException{ if(this.connection!=null || !this.connection.isClosed())this.connection.close(); } // @SuppressWarnings("unchecked") // public static BaseDao getSimpleDBAccess() { // String dataBaseName; // String serverIp; // String serverPort; // String dataBaseObject; // String userName; // String passWord; // String temp; // String[] useConnect = null; // Map<String, String[]> conTypes = new HashMap<String, String[]>(); // try { // String path = CommonData.getAppPath(AppMain.class); // SAXBuilder sb = new SAXBuilder(); // Document doc; // doc = sb.build(path + "/WebContent/META-INF/context.xml"); // Element ele = doc.getRootElement(); // List<Element> eles = ele.getChildren("Resource"); // for (Element each : eles) { // temp = each.getAttributeValue("name"); // dataBaseName = temp.substring(temp.indexOf("/") + 1); // userName = each.getAttributeValue("username"); // passWord = each.getAttributeValue("password"); // temp = each.getAttributeValue("url"); // temp = temp.substring(temp.indexOf("@") + 1); // serverIp = temp.substring(0, temp.indexOf(":")); // serverPort = temp.substring(temp.indexOf(":") + 1, temp // .lastIndexOf(":")); // dataBaseObject = temp.substring(temp.lastIndexOf(":") + 1); // String[] oneConnect = { serverIp, dataBaseObject, serverPort, // userName, passWord }; // conTypes.put(dataBaseName, oneConnect); // } // useConnect =conTypes.get(CommonData.dbType.getDataBaseName()); // // return DBAccess.getDBAccess(useConnect[0], useConnect[1], Integer // .parseInt(useConnect[2]), useConnect[3], useConnect[4]); // } catch (JDOMException e) { // e.printStackTrace(); // } catch (IOException e) { // e.printStackTrace(); // } // return null; // } /** * * @throws SQLException */ public void rollbackTransaction() throws SQLException { connection.rollback(); connection.setAutoCommit(true); } /** * * @throws SQLException */ public void commitTransaction() throws SQLException { connection.commit(); connection.setAutoCommit(true); } /** * @return 行数 * @throws SQLException */ public int executeNoneQuery() throws SQLException { int count; preparedStatement = connection.prepareStatement(sqlString, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); // statement = connection.prepareStatement(sqlString,1005,1008); prepareStatement(); count = preparedStatement.executeUpdate(); preparedStatement.close(); return count; } /** * * @return * @throws SQLException */ public int executeNoneQueryProcedure() throws SQLException { preparedStatement = connection.prepareCall(sqlString, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); prepareStatement(); registerOutParameters(); return preparedStatement.executeUpdate(); } public int[] executeBatch(List<String> sqlList) throws SQLException { Statement batchStatement = connection.createStatement(); for (String sql : sqlList) { batchStatement.addBatch(sql); } int[] re = batchStatement.executeBatch(); batchStatement.clearBatch(); batchStatement.close(); return re; } /** * 出力パラメータを取得する * * @param parameterIndex * パラメータ * @return パラメータの値 * @throws SQLException */ public Object getOutParameters(int parameterIndex) throws SQLException { return ((CallableStatement) preparedStatement).getObject(parameterIndex); } /** * * @return * @throws SQLException */ public ResultSet getQueryProcedureResultSet() throws SQLException { preparedStatement = connection.prepareCall(sqlString, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); prepareStatement(); registerOutParameters(); return preparedStatement.executeQuery(); } /** * データを取得する * * @return false: データを取得するが失敗です true:データを取得するが成功です * @throws ClassNotFoundException * @throws SQLException */ public ResultSet getQueryResultSet() throws SQLException { preparedStatement = connection.prepareStatement(sqlString, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY); prepareStatement(); return preparedStatement.executeQuery(); } /** * * @param parameterIndex * @param sqlType */ public void setOutParameter(int parameterIndex, int sqlType) { this.outParameters.put(parameterIndex, sqlType); } /** * * @param parameterIndex * @param parameter */ public void setParameter(int parameterIndex, Object parameter) { this.parameters.put(parameterIndex, parameter); } /** * * @param parameters */ public void setParameters(Object... parameters) { int i = 1; for (Object parameter : parameters) { this.parameters.put(i++, parameter); } } /** * * @throws SQLException */ private void registerOutParameters() throws SQLException { if (!outParameters.isEmpty()) { Set<Integer> keySet = outParameters.keySet(); for (int parameterIndex : keySet) { int sqlType = outParameters.get(parameterIndex); ((CallableStatement) preparedStatement).registerOutParameter( parameterIndex, sqlType); } } } /** * * @throws SQLException */ public void closeStatement() throws SQLException { preparedStatement.close(); } /** * @param sqlString * the sqlString to set */ public void setSqlString(String sqlString) { this.sqlString = sqlString; this.parameters.clear(); this.outParameters.clear(); } private void prepareStatement() throws SQLException { if (!parameters.isEmpty()) { Set<Integer> keySet = parameters.keySet(); for (int parameterIndex : keySet) { Object parameter = parameters.get(parameterIndex); int sqlType; if(parameter==null) sqlType=0;//add by zhangshiying 20081211(add Type is null) else sqlType = JavaSqlTypeConverter.getSqlType(parameter .getClass().getName()); switch (sqlType) { case java.sql.Types.NULL://add by zhangshiying 20081211(add Type is null) preparedStatement.setObject(parameterIndex, (Object) null); break; case java.sql.Types.INTEGER: preparedStatement.setInt(parameterIndex, (Integer) parameter); break; case java.sql.Types.VARCHAR: preparedStatement.setString(parameterIndex, (String) parameter); break; case java.sql.Types.BIGINT: preparedStatement.setLong(parameterIndex, (Long) parameter); break; case java.sql.Types.BOOLEAN: preparedStatement.setBoolean(parameterIndex, (Boolean) parameter); break; case java.sq