JSP连ORACLE的类文件

王朝oracle·作者佚名  2008-05-19
窄屏简体版  字體: |||超大  

import java.io.Reader;

import java.sql.*;

import javax.servlet.ServletRequest;

import javax.servlet.http.HttpServletRequest;

import oracle.jdbc.driver.OracleResultSet;

import oracle.sql.CLOB;

public class Db_sql

{

/**

* 构造函数,new Db_sql 的时候执行,调用 connect() 连接ORACLE数据库

*/

public Db_sql(String s, String s1, String s2, String s3, String s4)

throws Exception

{

isClosed = false;

host = s.trim();

port = s1.trim();

sid = s2.trim();

user = s3.trim();

password = s4.trim();

connMgr = DBConnectionManager.getInstance();

connect();

}

/**

* 连接ORACLE数据库

*/

public boolean connect()

throws Exception

{

String s = "jdbc:oracle:thin:@" + host + ":" + port + ":" + sid;

conn = connMgr.getConnection(user, s, user, password);

return true;

}

/**

* 是否自动 COMMIT

*/

public void setAutoCommit(boolean flag)

throws SQLException

{

bAutoCommit = flag;

conn.setAutoCommit(flag);

}

/**

* 没有设置成自动 COMMIT ,调用该方法才会 COMMIT

*/

public void commit()

throws SQLException

{

if(!bAutoCommit)

conn.commit();

}

/**

* 没有设置成自动 COMMIT ,调用该方法才会 ROLL BACK

*/

public void rollback()

throws SQLException

{

if(!bAutoCommit)

conn.rollback();

}

/**

* 执行 SQL ,返回执行结果 TRUE/FALSE

*/

public ResultSet query(String s)

throws Exception

{

if(stmt == null)

stmt = conn.createStatement();

if(result != null)

{

result.close();

result = null;

}

result = stmt.executeQuery(s);

return result;

}

public void queryLarge(String s, String s1)

throws Exception

{

stmt.execute(s);

ResultSet resultset = stmt.getResultSet();

if(resultset.next())

{

CLOB clob = ((OracleResultSet)resultset).getCLOB(1);

clob.putChars(1L, s1.toCharArray());

}

resultset.close();

}

/**

* 把结果集里的指针下移一位

*/

public boolean next()

throws SQLException

{

return result.next();

}

/**

* 取得当前记录的 INT 类型字段值,前后去空格

*/

public int getInt(String s)

throws SQLException

{

return result.getInt(s.trim());

}

/**

* 取得当前记录的 STRING 类型字段值,前后去空格

*/

public String getString(String s)

throws SQLException

{

return result.getString(s.trim());

}

/**

* 取得当前记录的 SHORT 类型字段值,前后去空格

*/

public short getShort(String s)

throws SQLException

{

return result.getShort(s.trim());

}

/**

* 取得当前记录的 LONG 类型字段值,前后去空格

*/

public long getLong(String s)

throws SQLException

{

return result.getLong(s.trim());

}

/**

* 取得当前记录的 DATE 类型字段值,前后去空格

*/

public Date getDate(String s)

throws SQLException

{

return result.getDate(s.trim());

}

/**

* 取得当前记录的 TIME 类型字段值,前后去空格

*/

public Time getTime(String s)

throws SQLException

{

return result.getTime(s.trim());

}

/**

* 取得当前记录的 FLOAT 类型字段值,前后去空格

*/

public float getFloat(String s)

throws SQLException

{

return result.getFloat(s.trim());

}

/**

* 取得当前记录的 DOUBLE 类型字段值,前后去空格

*/

public double getDouble(String s)

throws SQLException

{

return result.getDouble(s.trim());

}

/**

* 取得当前记录的 BOOLEAN 类型字段值,前后去空格

*/

public boolean getBoolean(String s)

throws SQLException

{

return result.getBoolean(s.trim());

}

/**

* 取得当前记录的 CLOB 类型字段值

*/

public String getText(String s)

throws SQLException

{

String s1 = "";

char ac[] = new char[200];

CLOB clob = (CLOB)result.getObject(s);

if(clob == null)

return null;

Reader reader = clob.getCharacterStream();

int i;

try

{

while((i = reader.read(ac, 0, 200)) != -1)

s1 = s1 + new String(ac, 0, i);

}

catch(Exception exception1)

{

throw new SQLException(exception1.getMessage());

}

finally

{

try

{

reader.close();

}

catch(Exception _ex) { }

}

return s1;

}

/**

* 关闭数据库连接,执行 COMMIT,RELEASE 动作

*/

public boolean close()

throws SQLException

{

if(result != null)

{

result.close();

result = null;

}

if(stmt != null)

{

stmt.close();

stmt = null;

}

conn.setAutoCommit(true);

connMgr.freeConnection(user, conn);

connMgr.release(user);

isClosed = true;

return true;

}

/**

* 没有调用 close() 时,执行 close()

*/

protected void finalize()

throws SQLException

{

if(!isClosed)

close();

}

/**

* 取得 HTTP 参数值,所有得到的值都做了

* String (request.getParameter(s.trim()).trim().getBytes("ISO8859_1"), "GB2312") 处理

*/

public static String getParameter(HttpServletRequest httpservletrequest, String s)

{

try

{

if(httpservletrequest.getParameter(s.trim()) != null)

return new String(httpservletrequest.getParameter(s.trim()).trim().getBytes("ISO8859_1"), "GB2312");

else

return null;

}

catch(Exception _ex)

{

return httpservletrequest.getParameter(s.trim());

}

}

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航