packagecom.dz.product.dao;importjava.io.IOException;importjava.io.InputStream;import java.sql.*;importjava.text.ParsePosition;importjava.text.SimpleDateFormat;import java.util.*;importjava.util.Date;public classDBUtil {//连接对象//Statement 命令对象//打开连接//关闭连接//得到一个连接对象//查询(有参，无参)//修改(有参，无参)

static Connection conn = null;static Statement stmt = null;static PreparedStatement pstmt=null;//驱动，服务器地址，登录用户名，密码

staticString DBDRIVER;staticString DBURL;staticString DBUID;staticString DBPWD;static{ DBDRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver";

DBURL = "jdbc:sqlserver://localhost:1433;databasename=YerGoMallPro";DBUID= "sa";//DBPWD = "@zdm168168...";

DBPWD = "123456";//打开连接

}

public static voidopen() {//加载驱动

try{

Class.forName(DBDRIVER);

conn=DriverManager.getConnection(DBURL,DBUID,DBPWD);

}catch(ClassNotFoundException e) {

e.printStackTrace();

}catch(SQLException e) {

e.printStackTrace();

}

}//关闭连接

public static voidclose() {try{if(stmt!=null)

stmt.close();if(conn!=null && !conn.isClosed())

conn.close();

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}

}//得到一个连接对象，当用户使用DBUtil无法解决个性问题时//可以通过本方法获得连接对象

public staticConnection getConnection() {try{if(conn==null ||conn.isClosed())

open();

}catch(SQLException e) {

e.printStackTrace();

}returnconn;

}//executeQuery//executeUpdate//execute//获得查询的数据集//select * from student where name='' and sex=''

public staticResultSet executeQuery(String sql) {try{

open();//保证连接是成功的

stmt =conn.createStatement();returnstmt.executeQuery(sql);

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}return null;

}//修改表格内容

public static intexecuteUpdate(String sql) {int result = 0;try{

open();//保证连接是成功的

stmt =conn.createStatement();

result=stmt.executeUpdate(sql);

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}finally{

close();

}returnresult;

}//如果执行的查询或存储过程，会返回多个数据集，或多个执行成功记录数//可以调用本方法，返回的结果，//是一个List或List集合

public staticObject execute(String sql) {boolean b=false;try{

open();//保证连接是成功的

stmt =conn.createStatement();

b=stmt.execute(sql);//true,执行的是一个查询语句，我们可以得到一个数据集//false,执行的是一个修改语句，我们可以得到一个执行成功的记录数

if(b){returnstmt.getResultSet();

}else{returnstmt.getUpdateCount();

}

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}finally{if(!b) {

close();

}

}return null;

}//

//select * from student where name=? and sex=?

public staticResultSet executeQuery(String sql,Object[] in) {try{

open();//保证连接是成功的

PreparedStatement pst =conn.prepareStatement(sql);for(int i=0;i

pst.setObject(i+1, in[i]);

stmt= pst;//只是为了关闭命令对象pst

returnpst.executeQuery();

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}return null;

}public static intexecuteUpdate(String sql,Object[] in) {try{

open();//保证连接是成功的

PreparedStatement pst =conn.prepareStatement(sql);for(int i=0;i

pst.setObject(i+1, in[i]);

stmt= pst;//只是为了关闭命令对象pst

returnpst.executeUpdate();

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}finally{

close();

}return 0;

}public staticPreparedStatement pstmt(String sql){

open();try{return pstmt =conn.prepareStatement(sql);

}catch(SQLException e) {//TODO 自动生成的 catch 块

e.printStackTrace();

}return null;

}public staticObject execute(String sql,Object[] in) {boolean b=false;try{

open();//保证连接是成功的

PreparedStatement pst =conn.prepareStatement(sql);for(int i=0;i

pst.setObject(i+1, in[i]);

b=pst.execute();//true,执行的是一个查询语句，我们可以得到一个数据集//false,执行的是一个修改语句，我们可以得到一个执行成功的记录数

if(b){

System.out.println("----");/*List list = new ArrayList();

list.add(pst.getResultSet());

while(pst.getMoreResults()) {

list.add(pst.getResultSet());

}*/

returnpst.getResultSet();

}else{

System.out.println("****");

List list = new ArrayList();

list.add(pst.getUpdateCount());while(pst.getMoreResults()) {

list.add(pst.getUpdateCount());

}returnlist;

}

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}finally{if(!b) {

System.out.println("====");

close();

}

}return null;

}//调用存储过程 proc_Insert(?,?,?)

public staticObject executeProcedure(String procName,Object[] in) {

open();try{

procName= "{call "+procName+"(";

String link="";for(int i=0;i

procName+=link+"?";

link=",";

}

procName+=")}";

CallableStatement cstmt=conn.prepareCall(procName);for(int i=0;i

cstmt.setObject(i+1, in[i]);

}if(cstmt.execute())

{returncstmt.getResultSet();

}else{returncstmt.getUpdateCount();

}

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}return null;

}/** 调用存储过程，并有输出参数

* @procName ，存储过程名称：proc_Insert(?,?)

* @in ,输入参数集合

* @output,输出参数集合

* @type,输出参数类型集合

**/

public staticObject executeOutputProcedure(String procName,

Object[] in,Object[] output,int[] type){

Object result= null;try{

CallableStatement cstmt= conn.prepareCall("{call "+procName+"}");//设置存储过程的参数值

int i=0;for(;i

cstmt.setObject(i+1, in[i]);//print(i+1);

}int len = output.length+i;for(;i

cstmt.registerOutParameter(i+1,type[i-in.length]);//print(i+1);

}boolean b =cstmt.execute();//获取输出参数的值

for(i=in.length;i

output[i-in.length] = cstmt.getObject(i+1);if(b) {

result=cstmt.getResultSet();

}else{

result=cstmt.getUpdateCount();

}

}catch(SQLException e) {//TODO Auto-generated catch block

e.printStackTrace();

}returnresult;

}//时间转换

public staticDate date(String date_str) {try{

Calendar cal= Calendar.getInstance();//日期类

Timestamp timestampnow = new Timestamp(cal.getTimeInMillis());//转换成正常的日期格式

SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");//改为需要的东西

ParsePosition pos = new ParsePosition(0);

java.util.Date current=formatter.parse(date_str, pos);

timestampnow= newTimestamp(current.getTime());returntimestampnow;

}catch(NullPointerException e) {return null;

}

};

}