import java.sql.Connection;
import java.sql.DriverManager;
public class UtilDbForOracle {
public static Connection getConnection(){
try{
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
String url = "jdbc:oracle:thin:@192.168.0.10:1521:ora920";
String username = "shihuan";
String password = "zznode";
Connection conn = DriverManager.getConnection(url, username, password);
// System.out.println(conn + "------return conn");
return conn;
}
catch (Exception e){
System.out.println(e.getMessage());
return null;
}
}
}
----------------------------------------------------------------------
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
public class DBOperaRule {
private Connection conn = null;
// private Statement stmt = null;
private PreparedStatement pstmt = null;
private ResultSet rs = null;
private boolean hadErrors = false;
//创建数据库连接
public void createConnection(){
conn = UtilDbForOracle.getConnection();
}
//发起事务
public void beginTransaction(){
try {
conn.setAutoCommit(false);
} catch (SQLException e) {
e.printStackTrace();
}
}
//执行事务
public void commitTransaction() throws SQLException{
if(!hadErrors){
conn.commit();
}else{
conn.rollback();
hadErrors = false ;
}
hadErrors = false ;
conn.setAutoCommit(true);
}
//标记出错
public void errorOccur(){
hadErrors = true ;
}
//执行插入、删除和更新操作
synchronized public void execute(String sql) throws SQLException {
this.pstmt = conn.prepareStatement(sql);
if(pstmt != null){
pstmt.executeUpdate(sql);
}else{
Log log = LogFactory.getLog("mylog");
log.error("数据库插入数据出错");
}
}
//执行查询操作
synchronized public ResultSet read(String sql) throws SQLException {
this.pstmt = conn.prepareStatement(sql);
// Statement stmt = conn.createStatement();
if(pstmt != null){
// if(stmt != null){
ResultSet tmp = null ;
tmp = pstmt.executeQuery(sql);
// tmp = stmt.executeQuery(sql);
//下面为打印数据表中的字段名称
// ResultSetMetaData md = tmp.getMetaData();
// for(int i=1; i<=md.getColumnCount(); i++){
// System.out.println(md.getColumnName(i));
// }
//循环打印数据库中的值
// while(tmp.next()){
// System.out.println("tmp是否在最后一行:" + tmp.isLast());
// System.out.println("row: " + tmp.getRow());
// System.out.println(tmp.getString(1) + " --> " + tmp.getString(2));
// }
return tmp;
}else{
return null;
}
}
//执行查询个数操作
synchronized public int readCount(String sql) throws SQLException {
this.pstmt = conn.prepareStatement(sql);
int nCount = 0;
try{
if(pstmt != null){
ResultSet tmp = null;
tmp = pstmt.executeQuery(sql);
if(tmp != null && tmp.next()){
nCount = tmp.getInt(1);
}else{
nCount = 0;
}
}
}catch(SQLException e){
nCount = 0;
}
return nCount;
}
//创建数据库连接
/*
public boolean createConnection(){
try{
conn = UtilDbForOracle.getConnection();
conn.setAutoCommit(false);
}catch(SQLException e){
System.out.println("createConnectionError!");
System.out.println(e.getMessage());
return false;
}
return true;
}
*/
//进行数据库增,删除,更新操作
/*
public boolean executeUpdate(String sql){
if(conn == null){
createConnection();
}
try{
stmt = con.createStatement();
int iCount = stmt.executeUpdate(sql);
System.out.println("操作成功,操作影响的记录数:" + String.valueOf(iCount));
}catch(SQLException e){
System.out.println("executeUpdateError!");
System.out.println(e.getMessage());
return false;
}
return true;
}
*/
/*
public boolean executeUpdateBatch(List list){
if(conn == null) createConnection();
try{
stmt = conn.createStatement();
for(int i = 0; i < list.size(); ++i)
stmt.addBatch((String) list.get(i));
int i[] = stmt.executeBatch();
System.out.println("操作成功,操作影响的记录数:" + i.length);
}catch(SQLException e){
System.out.println("executeUpdateBatchError!");
System.out.println(e.getMessage());
return false;
}
return true;
}
*/
//进行数据库查询操作
/*
public ResultSet executeQuery(String sql){
if(conn == null) createConnection();
try{
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);
}catch(SQLException e){
System.out.println("executeQueryError!");
System.out.println(e.getMessage());
return null;
}
return rs;
}
*/
/*
public List executeQueryForList(String s) throws SQLException{
ResultSet rs = this.executeQuery(s);
List list = new ArrayList();
HashMap hash;
String tmp = null;
int cols = rs.getMetaData().getColumnCount();
while(rs.next()){
hash = new HashMap();
for(int i = 1; i <= cols; i++){
tmp = rs.getString(i);
if(tmp == null)
tmp = "";
hash.put(rs.getMetaData().getColumnName(i).toLowerCase(), tmp);
}
list.add(hash);
hash = null;
}
return list;
}
*/
/*
public HashMap executeQueryForMap(String s) throws SQLException{
ResultSet rs = this.executeQuery(s);
HashMap hash = new HashMap();
String tmp = null;
int cols = rs.getMetaData().getColumnCount();
while(rs.next()){
hash = new HashMap();
for(int i = 1; i <= cols; i++){
tmp = rs.getString(i);
if(tmp == null)
tmp = "";
hash.put(rs.getMetaData().getColumnName(i).toLowerCase(), tmp);
}
}
return hash;
}
*/
/*
public ResultSet executeQueryForPage(String sql){
if(conn == null) createConnection();
try{
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
rs = stmt.executeQuery(sql);
}catch(SQLException e){
System.out.println("executeQueryError!");
System.out.println(e.getMessage());
return null;
}
return rs;
}
*/
//对数据库操作进行提交
/*
public boolean commit(){
try{
conn.commit();
}catch(SQLException e){
System.out.println("commitError!");
System.out.println(e.getMessage());
return false;
}
return true;
}
*/
//关闭数据库连接
public void closeDBConnection(){
if(conn != null){
try{
// stmt.close();
pstmt.close();
conn.close();
}catch(SQLException e){
System.out.println("closeDBConnectionError!");
e.printStackTrace();
}finally{
try{
// stmt.close();
pstmt.close();
}catch(SQLException e){
e.printStackTrace();
}
conn = null;
}
}
}
分享到:
相关推荐
JDBC实现Oracle数据库的增删改查
java使用JDBC和ODBC连接oracle数据库,虽然ODBC连接数据库不常用,但是大家还是可以了解一下
主要介绍了Java使用Jdbc连接Oracle执行简单查询操作,结合实例形式详细分析了java基于jdbc实现Oracle数据库的连接与查询相关操作技巧,需要的朋友可以参考下
java代码采用jdbc的方式连接oracle数据库的一个简单并且实用的示例,有视频文件,有源代码!!!和oracle驱动!!!!!!
JDBC连接Oracle数据库常见问题及解决方法
JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。
java通过jdbc连接oracle数据库.docx
JAVA-JDBC连接数据库(查询_添加_修改_删除)
这是java连接oracle的jar包,下载后,直接解压带入LIB下,即可使用, 这是java连接oracle的jar包,下载后,直接解压带入LIB下,即可使用,
java中的JDBC纯驱动方式连接Oracle数据库.docx
java使用jdbc将数据库数据导出到csv文件
java连接oracle数据库用的JDBC驱动!
JDBC连接oracle数据库
浅谈Java通过JDBC连接Oracle数据库技术.pdf
主要讲Java链接Oracle的JDBC链接方式
连接数据库,快速实现对oracle的连接
Java连接数据库JDBCoracle