datastore.java

系统特色: 1,栏目无限级分类,形成树型结构

package com.hao2007.struts.db;


import java.sql.*;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/*
 * 创建日期 2007-4-7
 *
 * TODO 要更改此生成的文件的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */

/**
 * @author jeffy522
 * 
 * TODO 要更改此生成的类型注释的模板，请转至 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
public class DataStore {

	private static DataStore db = null;

	private static Connection conn = null;

	private Statement stmt = null;   ///第一个Statement
	
	private Statement stmt1=null;     ///第二个Statement
	
	private boolean hadErrors = false;

	private DataStore() throws Exception {   //初始化构造函数,conn
		
			Class.forName("com.mysql.jdbc.Driver");
			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/new2007", "root",
					"120130");
		
	}
	
	public void beginTransaction() throws SQLException
    {
		conn.setAutoCommit(false);
    }
	
	public void commitTransaction() throws SQLException
    {
        if( !hadErrors ){
            conn.commit();
        }
        else{
        	conn.rollback();
        	hadErrors = false;
        }       

        hadErrors = false;
        conn.setAutoCommit(true);
    }

	public void ErrorOccur( ){
		hadErrors = true;
	}
	
	public static DataStore getInstance() {
		if (db == null) {
			try {
				db = new DataStore();
			} catch (Exception e) {
				conn = null;
				Log log = LogFactory.getLog("mylog");
				log.error("数据库连接出错-DataStore.java");
				return null;
			}
		}
		return db;

	}

	synchronized public void execute(String sql){
		try{
				stmt = conn.createStatement();
				stmt.executeUpdate(sql);
	
		}catch(SQLException e){
			
			Log log = LogFactory.getLog("mylog");
			log.error("数据库插入数据出错");
		}
	}

	synchronized public ResultSet read(String sql){
		ResultSet tmp = null;
		
		try{
				stmt = conn.createStatement();
				tmp = stmt.executeQuery(sql);
				return tmp;
		}catch(SQLException e){
			return null;
		}
	}
	
	///////////////////////////////////////////////
	synchronized public ResultSet read1(String sql){
		
		ResultSet tmp1=null;
		try{
				stmt1 = conn.createStatement();
				tmp1=stmt1.executeQuery(sql);
				return tmp1;

		}catch(SQLException e){
			return null;
		}
	}
	
	
	
	
	synchronized public int readCount( String sql ){
		int nCount = 0;
		
		try {
				ResultSet tmp = null;
				stmt = conn.createStatement();
				tmp = stmt.executeQuery(sql);
				if( tmp!=null && tmp.next() ) {
					nCount = tmp.getInt(1);
				}else {
					nCount = 0;
				}

		}catch(SQLException e) {
			nCount = 0;
		}
		
		return nCount;
	}

	synchronized public void stop() {
		try {
			if (conn != null) {
				conn.close();
				stmt.close();
			}
		} catch (Exception e) {
			/* 记录到日志 */
			Log log = LogFactory.getLog("mylog");
			log.error("数据库关闭出错-DataStore.java");
		} finally {
			conn = null;
		}
	}
	
	synchronized public void stop1(){
		try{
			if(conn!=null){
				conn.close();
				stmt1.close();
			}
		}catch(Exception e){
			/* 记录到日志 */
			Log log=LogFactory.getLog("mylog");
			log.error("数据库关闭出错-DataStore.java");
			
		}finally{
			conn=null;
		}
	}
	
	
	
}