FilesExpand file tree

 master

/

DB.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

102 lines (96 loc) · 2.46 KB

 master

/

DB.java

Copy path

Top

File metadata and controls

• Code
• Blame

102 lines (96 loc) · 2.46 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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();

}

}

}