数据库接口类(BasicDAO.java):实现对数据库的直接增删查改的interface接口
import java.sql.ResultSet;
public interface BasicDAO {
public int insert(String sql);
public int insert(String sql,Object[] obj);
public boolean update(String sql);
public boolean update(String sql,Object[] obj);
public boolean delete(String sql);
public boolean delete(String sql,Object[] obj);
public ResultSet select(String sql);
public ResultSet select(String sql,Object[] obj);
}
接口实现类(BasicDAOImpl.java):对BasicDAO接口的实现
DBHelper是数据库帮助类,具体请参考我的另一篇文章 Java连接MySQL数据库
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class BasicDAOImpl extends DBHelper implements BasicDAO {
Connection conn = null;
PreparedStatement pst = null;
ResultSet rs = null;
public void close(){
DBHelper.closeConnection(conn,pst,rs);
}
@Override
public int insert(String sql) {
try{
conn = DBHelper.getConnection();
pst = conn.prepareStatement(sql);
return pst.executeUpdate();
}catch (Exception e){
e.printStackTrace();
}
return 0;
}
@Override
public int insert(String sql, Object[] obj) {
try{
conn = DBHelper.getConnection();
pst = conn.prepareStatement(sql);
for (int i=0; i<obj.length; i++){
pst.setObject(i+1,obj[i]);
}
return pst.executeUpdate();
}catch (Exception e){
e.printStackTrace();
}
return 0;
}
@Override
public boolean update(String sql) {
try{
conn = DBHelper.getConnection();
pst = conn.prepareStatement(sql);
if(pst.executeUpdate()>0) return true;
}catch (Exception e){
e.printStackTrace();
}
return false;
}
@Override
public boolean update(String sql, Object[] obj) {
try{
conn = DBHelper.getConnection();
pst = conn.prepareStatement(sql);
for (int i=0; i<obj.length; i++){
pst.setObject(i+1,obj[i]);
}
if(pst.executeUpdate()>0) return true;
}catch (Exception e){
e.printStackTrace();
}
return false;
}
@Override
public boolean delete(String sql) {
try{
conn = DBHelper.getConnection();
pst = conn.prepareStatement(sql);
if(pst.executeUpdate()>0) return true;
}catch (Exception e){
e.printStackTrace();
}
return false;
}
@Override
public boolean delete(String sql, Object[] obj) {
try{
conn = DBHelper.getConnection();
pst = conn.prepareStatement(sql);
for (int i=0; i<obj.length; i++){
pst.setObject(i+1,obj[i]);
}
if(pst.executeUpdate()>0) return true;
}catch (Exception e){
e.printStackTrace();
}
return false;
}
@Override
public ResultSet select(String sql) {
try{
conn = DBHelper.getConnection();
pst = conn.prepareStatement(sql,PreparedStatement.RETURN_GENERATED_KEYS);
return pst.executeQuery();
}catch (Exception e){
e.printStackTrace();
}
return null;
}
@Override
public ResultSet select(String sql, Object[] obj) {
try{
conn = DBHelper.getConnection();pst = conn.prepareStatement(sql,PreparedStatement.RETURN_GENERATED_KEYS);
for (int i=0; i<obj.length; i++){
pst.setObject(i+1,obj[i]);
}
return pst.executeQuery();
}catch (Exception e){
e.printStackTrace();
}
return null;
}
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)