在学习JavaWeb时会用到此代码,用于实行增删改查操作
1 package com.bdqn.dao; import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* 数据库连接与关闭工具类。
* @author 北大青鸟
*/
public class BaseDao {
private static String driver =
"com.microsoft.sqlserver.jdbc.SQLServerDriver";// 数据库驱动字符串 private static String url =
"jdbc:sqlserver://localhost:3306;DatabaseName=Fruit";// 连接URL字符串
private static String user = "sa"; // 数据库用户名
private static String password = "bdqn"; // 用户密码 protected Connection conn;
protected PreparedStatement pstmt;
protected ResultSet rs;
/**
* 获取数据库连接对象。
*/
public Connection getConnection() {
Connection conn = null;// 数据连接对象
// 获取连接并捕获异常
try {
Class.forName(driver);
conn = DriverManager.getConnection(url, user, password);
} catch (Exception e) {
e.printStackTrace();// 异常处理
}
return conn;// 返回连接对象
}
/**
* 关闭数据库连接。
* @param conn 数据库连接
* @param stmt Statement对象
* @param rs 结果集
*/
public void closeAll(Connection conn, Statement stmt, ResultSet rs) {
// 若结果集对象不为空,则关闭
if (rs != null) {
try {
rs.close();
} catch (Exception e) {
e.printStackTrace();
}
}
// 若Statement对象不为空,则关闭
if (stmt != null) {
try {
stmt.close();
} catch (Exception e) {
e.printStackTrace();
}
}
// 若数据库连接对象不为空,则关闭
if (conn != null) {
try {
conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
* 增、删、改操作
* @param sql sql语句
* @param prams 参数数组
* @return 执行结果
*/
public int exceuteUpdate(String sql){ int result=0;
try {
conn = getConnection();
Statement stmt = conn.createStatement();
result = stmt.executeUpdate(sql); } catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} return result;
}
/**
* 查询操作
* @param sql sql语句
* @return rs
*/
public ResultSet exceuteQuery(String sql){ try {
conn = getConnection();
Statement stmt = conn.createStatement();
rs = stmt.executeQuery(sql); } catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rs;
}
}