FilesExpand file tree

 master

/

JDBConnection.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

69 lines (62 loc) · 1.72 KB

 master

/

JDBConnection.java

Copy path

Top

File metadata and controls

• Code
• Blame

69 lines (62 loc) · 1.72 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

package com.tools;

import java.sql.*;

public class JDBConnection {

private final static String url = "jdbc:mysql://localhost:3306/db_wlgl?user=root&password=111&useUnicode=true&characterEncoding=gb2312";

private final static String dbDriver = "com.mysql.jdbc.Driver";

private Connection con = null;

// 通过构造方法加载数据库驱动

static {

try {

Class.forName(dbDriver).newInstance();

} catch (Exception ex) {

System.out.println("数据库加载失败");

}

}

// 创建数据库连接

public boolean creatConnection() {

try {

con = DriverManager.getConnection(url);

con.setAutoCommit(true);

} catch (SQLException e) {

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

System.out.println("creatConnectionError!");

}

return true;

}

// 对数据库的增加、修改和删除的操作

public boolean executeUpdate(String sql) {

if (con == null) {

creatConnection();

}

try {

Statement stmt = con.createStatement();

int iCount = stmt.executeUpdate(sql);

System.out.println("操作成功，所影响的记录数为" + String.valueOf(iCount));

return true;

} catch (SQLException e) {

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

return false;

}

}

// 对数据库的查询操作

public ResultSet executeQuery(String sql) {

ResultSet rs;

try {

if (con == null) {

creatConnection();

}

Statement stmt = con.createStatement();

try {

rs = stmt.executeQuery(sql);

} catch (SQLException e) {

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

return null;

}

} catch (SQLException e) {

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

System.out.println("executeQueryError!");

return null;

}

return rs;

}

}