Java操作数据库之类的封装!...

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

class DBManager{

//定义成员变量

Connection conn =null;

Statement stmt =null;

ResultSet rst =null;

//创建数据库连接对象

public void getConnection(String dbIP,String dbPort,String dbName,String dbUser,String dbPassword){

//加载数据库驱动

try{

Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

}

catch(ClassNotFoundException e){

System.out.println("加载数据库驱动失败:\n"+e.toString());

return;

}

//开始连接数据库

try{

conn =DriverManager.getConnection("jdbc:sqlserver://"+dbIP+":"+dbPort+";databaseName="+dbName, dbUser, dbPassword);

}

catch (SQLException e) {

System.out.println("获取连接失败" + e.toString());

return;

}

}

//得到SQL执行对象

public Statement getStatement(){

try{

stmt =conn.createStatement();

}

catch(SQLException e){

System.out.println(e.toString());

return stmt =null;

}

return stmt;

}



//创建记录,即向数据库中插入数据

public int create(Statement stmt,String sqlCreate){

int nRecord=0;

try{

nRecord =stmt.executeUpdate(sqlCreate);

}

catch(SQLException e){

System.out.println(e.toString());

}



return nRecord;

}



//查询记录

public ResultSet read(Statement stmt,String sqlSelect){

ResultSet rst =null;

try{

rst =stmt.executeQuery(sqlSelect);

}

catch(SQLException e){

System.out.println(e.toString());

}



return rst;

}



//更新记录

public int update(Statement stmt,String sqlUpdate){

int nRecord=0;

try{

nRecord =stmt.executeUpdate(sqlUpdate);

}

catch(SQLException e){

System.out.println(e.toString());

}

return nRecord;

}



//删除记录

public int delete(Statement stmt,String sqlDelete){

int nRecord=0;

try{

nRecord =stmt.executeUpdate(sqlDelete);

}

catch(SQLException e){

System.out.println(e.toString());

}

return nRecord;

}



//关闭结果集

public void closeResultSet(ResultSet rs){

try{

rst.close();

}

catch(SQLException e){

System.out.println(e.toString());

return;

}

}

//关闭SQL语句执行对象

public void closeStatement(Statement stmt){

try{

stmt.close();

}

catch(SQLException e){

System.out.println(e.toString());

return;

}

}

//断开与数据库的连接

public void closeConnection(Connection conn){

try{

conn.close();

}

catch(SQLException e){

System.out.println(e.toString());

return;

}

}

}