forked from maxliaops/Java_Web_Examples
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathDB.java
More file actions
102 lines (96 loc) · 2.46 KB
/
DB.java
File metadata and controls
102 lines (96 loc) · 2.46 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
package com.toolsBean;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class DB {
private Connection con;
private PreparedStatement pstm;
private String user="sa";
private String password="";
private String className="com.microsoft.sqlserver.jdbc.SQLServerDriver";
private String url="jdbc:sqlserver://localhost:1433;DatabaseName=db_mediaBlog";
/** 构造方法，在该方法中加载数据库驱动 */
public DB(){
try{
Class.forName(className);
}catch(ClassNotFoundException e){
System.out.println("加载数据库驱动失败！");
e.printStackTrace();
}
}
/**创建数据库连接*/
public Connection getCon(){
if(con==null){
try {
con=DriverManager.getConnection(url,user,password);
} catch (SQLException e) {
System.out.println("创建数据库连接失败！");
con=null;
e.printStackTrace();
}
}
return con;
}
/**
*@功能：对数据库进行增、删、改、查操作
*@参数：sql为SQL语句；params为Object数组，里面存储的是为sql表示的SQL语句中"?"占位符赋值的数据
*/
public void doPstm(String sql,Object[] params){
if(sql!=null&&!sql.equals("")){
if(params==null)
params=new Object[0];
getCon();
if(con!=null){
try{
System.out.println(sql);
pstm=con.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
for(int i=0;i<params.length;i++){
pstm.setObject(i+1,params[i]);
}
pstm.execute();
}catch(SQLException e){
System.out.println("doPstm()方法出错！");
e.printStackTrace();
}
}
}
}
/**
* @功能：获取调用doPstm()方法执行查询操作后返回的ResultSet结果集
* @返回值：ResultSet
* @throws SQLException
*/
public ResultSet getRs() throws SQLException{
return pstm.getResultSet();
}
/**
* @功能：获取调用doPstm()方法执行更新操作后返回影响的记录数
* @返回值：int
* @throws SQLException
*/
public int getCount() throws SQLException{
return pstm.getUpdateCount();
}
/**
* @功能：释放PrepareStatement对象与Connection对象
*/
public void closed(){
try{
if(pstm!=null)
pstm.close();
}catch(SQLException e){
System.out.println("关闭pstm对象失败！");
e.printStackTrace();
}
try{
if(con!=null){
con.close();
}
}catch(SQLException e){
System.out.println("关闭con对象失败！");
e.printStackTrace();
}
}
}