dbconnection.java

关于shopmanager的源码

package common;

import   java.sql.*;

public class DBConnection {
	
	private Connection  con;
	private PreparedStatement  ps;
	private ResultSet  rs;
	private String  driver="com.mysql.jdbc.Driver";
	private String  url="jdbc:mysql://localhost:3306/GWB";
	private String  username="root";
	private String  password="123";
	
	public  DBConnection()
	{
		try
		{
			Class.forName(driver);
		}
		catch(ClassNotFoundException e)
		{
			System.err.print("对不起.找不到驱动器");
		}
		try
		{
			con=DriverManager.getConnection(url,username,password);
		}
		catch(SQLException ve)
		{
			System.err.print("对不起,连接不上数据库");
		}
	}
	
	public ResultSet executeQuery(String sql, String[] values) throws Exception {
		ps = con.prepareStatement(sql);
		if (values != null) {
			for (int i = 0; i < values.length; i++) {
				ps.setString(i + 1, values[i]);
			}
		}
		rs = ps.executeQuery();
		return rs;
	}

	public int executeUpdate(String sql, String[] values) throws Exception {
		ps = con.prepareStatement(sql);
		if (values != null) {
			for (int i = 0; i < values.length; i++) {
				ps.setString(i + 1, values[i]);
			}
		}
		return ps.executeUpdate();
	}
	
	public int executeUpdates(String sql, String values) throws Exception {
		ps = con.prepareStatement(sql);
		if (values != null) {
			for (int i = 0; i <100; i++) {
				ps.setString(i+1, values);
			}
		}
		return ps.executeUpdate();
	}
	
	
	public ResultSet executeQuerys(String sql, String values) throws Exception {
		ps = con.prepareStatement(sql);
		if (values != null) {
			for (int i = 0; i <100; i++) {
				ps.setString(i+1, values);
			}
		}
		rs = ps.executeQuery();
		return rs;
	}
	
	public  void  close()
	{
	  if(con!=null)
  	  {
  		  try
  		  {
  			  con.close();
  		  }
  		  catch(SQLException ae)
  		  {
  			  System.err.println(ae.getMessage());
  		  }
  	  }  
  	  if(ps!=null)
  	  {
  		  try
  		  {
  			  ps.close();
  		  }
  		  catch(SQLException ae)
  		  {
  			  System.err.println(ae.getMessage());
  		  }
  	  } 
  	  if(rs!=null)
  	  {
  		  try
  		  {
  			  rs.close();
  		  }
  		  catch(SQLException ae)
  		  {
  			  System.err.println(ae.getMessage());
  		  }
  	  }
	}

}