Java利用JDBC連接數據庫
1
package test.capture;
2
3
import java.sql.Connection;
4
import java.sql.DriverManager;
5
import java.sql.ResultSet;
6
import java.sql.SQLException;
7
import java.sql.Statement;
8
9
public class DBAccess {
10
/**
11
* connection parameters
12
*/
13
private Connection conn;
14
private Statement stmt;
15
String driver = "oracle.jdbc.driver.OracleDriver";
16
String url = "jdbc:oracle:thin:@192.168.0.117:1521:QEWAY";
17
String userName = "hangfatest";
18
String password = "hangfatest";
19
public Connection getConn() {
20
return conn;
21
}
22
public void setConn(Connection conn) {
23
this.conn = conn;
24
}
25
public Statement getStmt() {
26
return stmt;
27
}
28
public void setStmt(Statement stmt) {
29
this.stmt = stmt;
30
}
31
32
public DBAccess(){
33
this.setDriver(driver);
34
this.setConnection(url, userName, password);
35
}
36
public DBAccess(String driver, String url, String userName, String password){
37
try{
38
conn = DriverManager.getConnection(url,userName,password);
39
stmt = conn.createStatement();
40
}catch(SQLException e){
41
e.printStackTrace();
42
}
43
}
44
45
/**
46
* setDriver
47
*/
48
public boolean setDriver(String driver){
49
try{
50
Class.forName(driver);
51
return true;
52
}catch(Exception e){
53
e.printStackTrace();
54
}
55
return false;
56
}
57
/**
58
* setConnection
59
*/
60
public boolean setConnection(String url, String userName, String password){
61
try{
62
conn = DriverManager.getConnection(url,userName,password);
63
stmt = conn.createStatement();
64
return true;
65
}catch(Exception e){
66
e.printStackTrace();
67
}
68
return false;
69
}
70
/**
71
* 處理查詢
72
*/
73
public ResultSet sendQuery(String sql){
74
try{
75
ResultSet rs = stmt.executeQuery(sql);
76
return rs;
77
}catch(SQLException e){
78
e.printStackTrace();
79
return null;
80
}
81
}
82
/**
83
* 處理數據更新
84
*/
85
public int sendUpdate(String sql){
86
try{
87
return stmt.executeUpdate(sql);
88
}catch(SQLException e){
89
e.printStackTrace();
90
return -1;
91
}
92
}
93
94
/**
95
* main TEST
96
*/
97
public static void main(String[] args) {
98
DBAccess db = new DBAccess();
99
String sql = "select * from SYS_BILL_NO";
100
ResultSet rs = db.sendQuery(sql);
101
try{
102
if(rs != null){
103
while(rs.next()){
104
System.out.println(rs.getString("KEY_NAME")+ " " +
105
rs.getString("NEXT_VALUE"));
106
}
107
}
108
}catch(Exception e){
109
e.printStackTrace();
110
}
111
112
}
113
}
114

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

103

104

105

106

107

108

109

110

111

112

113

114

posted on 2009-07-16 18:57 彭偉 閱讀(153) 評論(0) 編輯 收藏 所屬分類: java技術分區