|
1
29
30 package com.caucho.quercus.lib.db;
31
32 import com.caucho.quercus.annotation.Optional;
33 import com.caucho.quercus.env.Env;
34 import com.caucho.quercus.env.LongValue;
35 import com.caucho.quercus.env.StringValueImpl;
36 import com.caucho.util.L10N;
37
38 import java.sql.Connection  ;
39 import java.sql.ResultSet ;
40 import java.sql.SQLException ;
41 import java.sql.Statement ;
42 import java.util.logging.Level ;
43 import java.util.logging.Logger ;
44
45
48 public class Oracle extends JdbcConnectionResource {
49 private static final Logger log = Logger.getLogger(Oracle.class.getName());
50 private static final L10N L = new L10N(Oracle.class);
51
52 public Oracle(Env env,
53 @Optional("localhost") String host,
54 @Optional String user,
55 @Optional String password,
56 @Optional String db,
57 @Optional("1521") int port,
58 @Optional String driver,
59 @Optional String url)
60 {
61 super(env);
62
63 connectInternal(env, host, user, password, db, port, "", 0, driver, url);
64 }
65
66
69 public boolean connectInternal(Env env,
70 @Optional("localhost") String host,
71 @Optional String userName,
72 @Optional String password,
73 @Optional String dbname,
74 @Optional("5432") int port,
75 @Optional String socket,
76 @Optional int flags,
77 @Optional String driver,
78 @Optional String url)
79 {
80 if (isConnected()) {
81 env.warning(L.l("Connection is already opened to '{0}'", this));
82 return false;
83 }
84
85 try {
86
87 if (host == null || host.equals(""))
88 host = "localhost";
89
90 if (driver == null || driver.equals("")) {
91 driver = "oracle.jdbc.OracleDriver";
92 }
93
94 if (url == null || url.equals("")) {
95 if (dbname.indexOf("//") == 0) {
96 url = "jdbc:oracle:thin:@" + dbname.substring(2);
98 url = url.replace('/', ':');
99 } else {
100 url = "jdbc:oracle:thin:@" + host + ":" + port + ":" + dbname;
101 }
102 }
103
104 Connection jConn = env.getConnection(driver, url, userName, password);
105
106 setConnection(host, userName, password, dbname, port, jConn, driver, url);
107
108 return true;
109
110 } catch (SQLException e) {
111 env.warning("A link to the server could not be established. " + e.toString());
112 env.setSpecialValue("oracle.connectErrno",new LongValue(e.getErrorCode()));
113 env.setSpecialValue("oracle.connectError", new StringValueImpl(e.getMessage()));
114
115 log.log(Level.FINE, e.toString(), e);
116
117 return false;
118 } catch (Exception e) {
119 env.warning("A link to the server could not be established. " + e.toString());
120 env.setSpecialValue("oracle.connectError", new StringValueImpl(e.getMessage()));
121
122 log.log(Level.FINE, e.toString(), e);
123 return false;
124 }
125 }
126
127
130 public OracleStatement prepare(Env env, String query)
131 {
132 OracleStatement stmt = new OracleStatement((Oracle) validateConnection());
133
134 stmt.prepare(query);
135
136 return stmt;
137 }
138
139
142 protected JdbcResultResource createResult(Statement stmt,
143 ResultSet rs)
144 {
145 return new OracleResult(stmt, rs, this);
146 }
147
148
149 public String toString()
150 {
151 if (isConnected())
152 return "Oracle[" + getHost() + "]";
153 else
154 return "Oracle[]";
155 }
156 }
157 |
Popular Tags |
Java API By Example, From Geeks To Geeks.