dataprocess.java

java语言编写的程序

package cn.lab.dbquery;
import java.sql.*;
public class DataProcess {

	public DataProcess() {
	}
	public static Connection getConnection()
	{
		String CLASSFORNAME="org.gjt.mm.mysql.Driver";
		String SERVANDDB="jdbc:mysql://localhost:3306/wangzhan?"
			+"user=root&password=root&useUnicode=true&characterEncoding=gb2312";
		Connection con;
	
	try
	{
		Class.forName(CLASSFORNAME);
		con = DriverManager.getConnection(SERVANDDB);
		return con;
	}
	catch(Exception e)
	{
		e.printStackTrace();
		return null;
	}
}
	public static int nCount(String SQL)
	{
		Connection myConnection = getConnection();
		int count = 0;
		try
		{
			Statement stm = myConnection.createStatement();
			ResultSet result = stm.executeQuery(SQL);
			if(result.next())
			{
				count = result.getInt(1);
				result.close();
			}
			stm.close();
			myConnection.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
		return count;
	}
	
	public static void ExeQuery(String SQL)
	{
		Connection con = getConnection();
		try
		{
			Statement stmt = con.createStatement();
			stmt.executeUpdate(SQL);
			stmt.close();
			con.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
	public static ResultSet getResult(String SQL,Connection con)
	{
		ResultSet rs = null;
		try{
			Statement stmt = con.createStatement();
			rs = stmt.executeQuery(SQL);
			stmt.close();
		}
		catch(SQLException e)
		{
			e.printStackTrace();
		}
		return rs;
	}
	
	public static void CloseConnection(Connection con)
	{
		try
		{
			con.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
	public static void CloseResultSet(ResultSet rs)
	{
		try
		{
			rs.close();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
}