FilesExpand file tree

 master

/

ConnDB.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

94 lines (88 loc) · 2.46 KB

 master

/

ConnDB.java

Copy path

Top

File metadata and controls

• Code
• Blame

94 lines (88 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

package com.core;

import java.io.InputStream;

import java.sql.*;

import java.util.Properties;

public class ConnDB {

public Connection conn = null;

public Statement stmt = null;

public ResultSet rs = null;

private static String propFileName = "/com/connDB.properties"; //指定资源文件保存的位置

private static Properties prop = new Properties();

private static String dbClassName ="com.mysql.jdbc.Driver";

private static String dbUrl =

"jdbc:mysql://127.0.0.1:3306/db_librarySys?user=root&password=111&useUnicode=true";

public ConnDB(){

try {

InputStream in=getClass().getResourceAsStream(propFileName);

prop.load(in); //通过输入流对象加载Properties文件

dbClassName = prop.getProperty("DB_CLASS_NAME"); //获取数据库驱动

dbUrl = prop.getProperty("DB_URL",dbUrl);

}

catch (Exception e) {

e.printStackTrace(); //输出异常信息

}

}

public static Connection getConnection() {

Connection conn = null;

try {

Class.forName(dbClassName).newInstance();

conn = DriverManager.getConnection(dbUrl);

}

catch (Exception ee) {

ee.printStackTrace();

}

if (conn == null) {

System.err.println(

"警告: DbConnectionManager.getConnection() 获得数据库链接失败.\r\n\r\n链接类型:" +

dbClassName + "\r\n链接位置:" + dbUrl);

}

return conn;

}

/*

* 功能：执行查询语句

*/

public ResultSet executeQuery(String sql) {

try {

conn = getConnection();

stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,

ResultSet.CONCUR_READ_ONLY);

rs = stmt.executeQuery(sql);

} catch (SQLException ex) {

System.err.println(ex.getMessage());

}

return rs;

}

/*

* 功能:执行更新操作

*/

public int executeUpdate(String sql) {

int result = 0;

try {

conn = getConnection(); //调用getConnection()方法构造Connection对象的一个实例conn

stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,

ResultSet.CONCUR_READ_ONLY);

result = stmt.executeUpdate(sql); //执行更新操作

} catch (SQLException ex) {

result = 0;

}

return result;

}

/*

* 功能:关闭数据库的连接

*/

public void close() {

try {

if (rs != null) {

rs.close();

}

if (stmt != null) {

stmt.close();

}

if (conn != null) {

conn.close();

}

} catch (Exception e) {

e.printStackTrace(System.err);

}

}

}