mymdb.java

设备资产管理源代码和 公共的函数

// Decompiled by Jad v1.5.8e2. Copyright 2001 Pavel Kouznetsov.
// Jad home page: http://kpdus.tripod.com/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi space 
// Source File Name:   MyMDB.java

package carven;

import com.bitmechanic.sql.ConnectionPoolManager;
import java.sql.*;

// Referenced classes of package carven:
//			JTable

public class MyMDB
{

	private String dbURL;
	private String dbUserName;
	private String dbPassword;
	private String dbDriverClass;
	private boolean bPool;
	private String alias;

	public MyMDB(String dbURL, String dbUserName, String dbPassword, String dbDriverClass)
		throws Exception
	{
		bPool = false;
		this.dbURL = dbURL;
		this.dbUserName = dbUserName;
		this.dbPassword = dbPassword;
		this.dbDriverClass = dbDriverClass;
		Class.forName(dbDriverClass).newInstance();
	}

	public MyMDB(String dbURL, String dbUserName, String dbPassword, String dbDriverClass, int maxConnection)
		throws Exception
	{
		bPool = true;
		ConnectionPoolManager pool = new ConnectionPoolManager(300);
		alias = String.valueOf(hashCode());
		pool.addAlias(alias, dbDriverClass, dbURL, dbUserName, dbPassword, maxConnection, 300, 120, 30, false);
	}

	private Connection Open()
		throws Exception
	{
		Connection conn;
		if (bPool)
			conn = DriverManager.getConnection("jdbc:bitmechanic:pool:" + alias, null, null);
		else
			conn = DriverManager.getConnection(dbURL, dbUserName, dbPassword);
		return conn;
	}

	public void ExeSql(String sql)
		throws Exception
	{
		Connection conn = Open();
		try
		{
			Statement comm = conn.createStatement();
			comm.execute(sql);
			comm.close();
		}
		catch (Exception ee)
		{
			throw new Exception("【error on execute this:" + sql + "】" + ee.toString());
		}
		
	}

	public void ExeSql(String sql[])
		throws Exception
	{
		Connection conn;
		Statement comm;
		conn = Open();
		comm = null;
		try
		{
			conn.setAutoCommit(false);
			try
			{
				comm = conn.createStatement();
				for (int i = 0; i < sql.length; i++)
					comm.execute(sql[i]);

				conn.commit();
			}
			catch (Exception ex)
			{
				conn.rollback();
				throw ex;
			}
		}
		catch (Exception ee)
		{
			throw new Exception("【error on execute this:" + sql + "】" + ee.toString());
		}
	}

	public int ExeUpdate(String sql)
		throws Exception
	{
		Connection conn = Open();
		int i;
		Statement comm = conn.createStatement();
		int result = comm.executeUpdate(sql);
		comm.close();
		i = result;
		conn.close();
		return i;

	}

	public int ExeUpdate(String sql[])
		throws Exception
	{
		Connection conn;
		Statement comm;
		conn = Open();
		comm = null;
		int j;
		int result = 0;
		conn.setAutoCommit(false);
		try
		{
			comm = conn.createStatement();
			for (int i = 0; i < sql.length; i++)
				if (i == sql.length - 1)
					result = comm.executeUpdate(sql[i]);
				else
					comm.execute(sql[i]);

			conn.commit();
		}
		catch (Exception ex)
		{
			conn.rollback();
			throw ex;
		}
		j = result;
		comm.close();
		conn.close();
		return j;

	}

	public String QueryOne(String sql)
		throws Exception
	{
		String returnStr;
		Connection conn;
		returnStr = null;
		conn = Open();
		String s;
		Statement comm = conn.createStatement();
		ResultSet rs = comm.executeQuery(sql);
		if (rs.next())
			returnStr = rs.getString(1);
		rs.close();
		comm.close();
		s = returnStr;
		conn.close();
		return s;
		
	
	}

	public String QueryOne(String sql[])
		throws Exception
	{
		String returnStr;
		Statement comm;
		Connection conn;
		returnStr = null;
		comm = null;
		conn = Open();
		String s;
		comm = conn.createStatement();
		conn.setAutoCommit(false);
		try
		{
			for (int i = 0; i < sql.length; i++)
				if (i == sql.length - 1)
				{
					ResultSet rs = comm.executeQuery(sql[i]);
					if (rs.next())
						returnStr = rs.getString(1);
					rs.close();
				} else
				{
					comm.execute(sql[i]);
				}

			conn.commit();
		}
		catch (Exception ex)
		{
			conn.rollback();
		}
		s = returnStr;
		comm.close();
		conn.close();
		return s;
		
	}

	public JTable QueryTable(String sql)
		throws Exception
	{
		Connection conn = Open();
		JTable jtable;
		JTable jTable = new JTable();
		Statement comm = conn.createStatement();
		ResultSet rs = comm.executeQuery(sql);
		jTable.FillTable(rs);//糶