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());
}
}
}
{
//创建数据库驱动程序字符串
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());
}
}
}
解决方案 »
免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货