package data;import java.sql.*;public class goodsdata
{
 //创建数据库驱动程序字符串
 String driver = "org.gjt.mm.mysql.Driver";
 //创建url字符串
 String url = "jdbc:mysql://localhost:3306/databaseName?user=root&password=123456";
 Connection conn = null;
 Statement stmt = null;
  ResultSet rs = null;
 public goodsdata()
 {
  try{
   //注册数据库驱动程序
   Class.forName(driver);
   //建立数据库连接
   conn = DriverManager.getConnection(url);
  }
  catch(Exception ex){
   ex.printStackTrace();
  }
 }
 //取得数据库连接的方法
 public Connection getConn()
 {
  return conn;
 }
 //数据库查询//sql:SQL查询语句
 public ResultSet query(String sql)
 {
  try{
   stmt=conn.createStatement();
   rs=stmt.executeQuery(sql);
  }catch(SQLException ex) {
   System.err.println("数据库查询错误:" + ex.getMessage());
  }
  return rs;
 }
 //数据库添加、修改、删除
 public void update(String sql)
 {
  try{
   stmt=conn.createStatement();
   stmt.executeUpdate(sql);
  }catch(SQLException ex) {
   System.err.println("数据库更新错误:"+ex.getMessage());
  }
 }
 //得到查询结果的总记录数//rs:查询结果集
 public int totalRecord(ResultSet rs) throws Exception
 {
  int total=0;
  //指针移到最后一条记录上
  rs.last();
  total = rs.getRow();
  rs.first();
  return total;
 }//关闭数据集
 public void closestmt()
 {
  try{
   stmt.close();
  }catch(SQLException ex) {
   System.err.println("数据集关闭错误:"+ex.getMessage());
  }
 }
 //关闭数据库连接
 public void closeconn()
 {
  try{
   conn.close();
  }catch(SQLException ex) {
   System.err.println("数据库连接关闭错误:"+ex.getMessage());
  }
 }
}