当前位置:  编程技术>java/j2ee

Java使用JDBC连接Oracle_MSSQL实例代码

    来源: 互联网  发布时间：2014-10-31

    本文导语:  一、Statement 代码如下:import java.sql.*; public class TestJDBC {  public static void main(String[] args) {  Connection oracle_conn = null;  Statement oracle_stmt = null;  ResultSet oracle_rs = null;  Connection mssql_conn = null;  Statement mssql_stmt = null;  ResultSet mssql...

一、Statement

代码如下:

import java.sql.*;

public class TestJDBC {

 public static void main(String[] args) {
  Connection oracle_conn = null;
  Statement oracle_stmt = null;
  ResultSet oracle_rs = null;

  Connection mssql_conn = null;
  Statement mssql_stmt = null;
  ResultSet mssql_rs = null;

  try {
   Class.forName("oracle.jdbc.driver.OracleDriver");
   oracle_conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.215:1521:orcl", "username", "password");

   oracle_stmt = oracle_conn.createStatement();

   Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
   mssql_conn = DriverManager.getConnection("jdbc:sqlserver://192.168.0.213:1433;DatabaseName=VIS", "username", "password");

   mssql_stmt = mssql_conn.createStatement();
   mssql_rs = mssql_stmt.executeQuery("select * from VideoBaseInfo");

   while(mssql_rs.next()) {
    System.out.println("正在插入VideoId：" + mssql_rs.getInt("VideoId") + "的记录...");
    oracle_stmt.executeUpdate("insert into VIDEO_BASEINFO values("
      + mssql_rs.getInt("VideoId") + ",'"
      + mssql_rs.getString("VideoName") + "','"
      + mssql_rs.getString("VideoVersion") + "',"
      + mssql_rs.getInt("VideoMp4Items") + ","
      + mssql_rs.getInt("VideoRmvbItems") + ",'"
      + mssql_rs.getString("VideoAliasName") + "','"
      + mssql_rs.getString("VideoAge") + "'"
      + ")");
   }

  } catch (ClassNotFoundException e) {
   e.printStackTrace();
  } catch (SQLException e) {
   e.printStackTrace();
  } finally {
   try {
    if(oracle_rs != null) {
     oracle_rs.close();
     oracle_rs = null;
    }

    if(oracle_stmt != null) {
     oracle_stmt.close();
     oracle_stmt = null;
    }

    if(oracle_conn != null) {
     oracle_conn.close();
     oracle_conn = null;
    }

    if(mssql_rs != null) {
     mssql_rs.close();
     mssql_rs = null;
    }

    if(mssql_stmt != null) {
     mssql_stmt.close();
     mssql_stmt = null;
    }

    if(mssql_conn != null) {
     mssql_conn.close();
     mssql_conn = null;
    }
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
 }

}

二、PreparedStatement

代码如下:

import java.sql.*;

public class TestPreparedStatement {

 public static void main(String[] args) {
  Connection oracle_conn = null;
  PreparedStatement oracle_stmt = null;
  ResultSet oracle_rs = null;

  Connection mssql_conn = null;
  Statement mssql_stmt = null;
  ResultSet mssql_rs = null;

  try {
   Class.forName("oracle.jdbc.driver.OracleDriver");
   oracle_conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.215:1521:orcl", "username", "password");

   oracle_stmt = oracle_conn.prepareStatement("insert into Video_ItemInfo values(?, ?, ?, ?, ?, ?, ?, ?, ?)");

   Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
   mssql_conn = DriverManager.getConnection("jdbc:sqlserver://192.168.0.213:1433;DatabaseName=VIS", "username", "password");

   mssql_stmt = mssql_conn.createStatement();
   mssql_rs = mssql_stmt.executeQuery("select * from VideoItemInfo");

   while(mssql_rs.next()) {
    System.out.println("正在插入ItemIndex：" + mssql_rs.getInt("ItemIndex") + "的记录...");
    oracle_stmt.setInt(1, mssql_rs.getInt("ItemIndex"));
    oracle_stmt.setInt(2, mssql_rs.getInt("VideoId"));
    oracle_stmt.setString(3, mssql_rs.getString("VideoItemName"));
    oracle_stmt.setString(4, mssql_rs.getString("VideoExtName"));
    oracle_stmt.setDouble(5, mssql_rs.getDouble("VideoSize"));
    oracle_stmt.setString(6, mssql_rs.getString("VideoPath"));
    oracle_stmt.setString(7, mssql_rs.getString("VideoType"));
    oracle_stmt.setDate(8, mssql_rs.getDate("VideoDate"));
    oracle_stmt.setString(9, mssql_rs.getString("ApplicationWay"));

    oracle_stmt.executeUpdate();
   }
   System.out.println("插入数据到Video_ItemInfo表中操作已完成！");
  } catch (ClassNotFoundException e) {
   e.printStackTrace();
  } catch (SQLException e) {
   e.printStackTrace();
  } finally {
   try {
    if(oracle_rs != null) {
     oracle_rs.close();
     oracle_rs = null;
    }

    if(oracle_stmt != null) {
     oracle_stmt.close();
     oracle_stmt = null;
    }

    if(oracle_conn != null) {
     oracle_conn.close();
     oracle_conn = null;
    }

    if(mssql_rs != null) {
     mssql_rs.close();
     mssql_rs = null;
    }

    if(mssql_stmt != null) {
     mssql_stmt.close();
     mssql_stmt = null;
    }

    if(mssql_conn != null) {
     mssql_conn.close();
     mssql_conn = null;
    }
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }
 }
}

三、CallableStatement

代码如下:

import java.sql.*;
public class TestProc {

 /**
  * @param args
  */
 public static void main(String[] args) throws Exception {

  Class.forName("oracle.jdbc.driver.OracleDriver");
  Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.1:1521:SXT", "scott", "tiger");
  CallableStatement cstmt = conn.prepareCall("{call p(?, ?, ?, ?)}");
  cstmt.registerOutParameter(3, Types.INTEGER);
  cstmt.registerOutParameter(4, Types.INTEGER);
  cstmt.setInt(1, 3);
  cstmt.setInt(2, 4);
  cstmt.setInt(4, 5);
  cstmt.execute();
  System.out.println(cstmt.getInt(3));
  System.out.println(cstmt.getInt(4));
  cstmt.close();
  conn.close();
 }
}

四、Batch

代码如下:

import java.sql.*;
public class TestBatch {


 public static void main(String[] args) throws Exception {
  Class.forName("oracle.jdbc.driver.OracleDriver");
  Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.1:1521:SXT", "scott", "tiger");
  /*
  Statement stmt = conn.createStatement();
  stmt.addBatch("insert into dept2 values (51, '500', 'haha')");
  stmt.addBatch("insert into dept2 values (52, '500', 'haha')");
  stmt.addBatch("insert into dept2 values (53, '500', 'haha')");
  stmt.executeBatch();
  stmt.close();
  */

  PreparedStatement ps = conn.prepareStatement("insert into dept2 values (?, ?, ?)");
  ps.setInt(1, 61);
  ps.setString(2, "haha");
  ps.setString(3, "bj");
  ps.addBatch();

  ps.setInt(1, 62);
  ps.setString(2, "haha");
  ps.setString(3, "bj");
  ps.addBatch();

  ps.setInt(1, 63);
  ps.setString(2, "haha");
  ps.setString(3, "bj");
  ps.addBatch();

  ps.executeBatch();
  ps.close();

  conn.close();

 }
}

五、Transaction

代码如下:

import java.sql.*;
public class TestTransaction {


 public static void main(String[] args) {

  Connection conn = null;
  Statement stmt = null;

  try {
   Class.forName("oracle.jdbc.driver.OracleDriver");
   conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:SXT", "scott", "tiger");

   conn.setAutoCommit(false);
   stmt = conn.createStatement();
   stmt.addBatch("insert into dept2 values (51, '500', 'haha')");
   stmt.addBatch("insert into dept2 values (52, '500', 'haha')");
   stmt.addBatch("insert into dept2 values (53, '500', 'haha')");
   stmt.executeBatch();
   conn.commit();
   conn.setAutoCommit(true);
  } catch (ClassNotFoundException e) {
   e.printStackTrace();
  } catch(SQLException e) {

   e.printStackTrace();

   try {
    if(conn != null)
    {
     conn.rollback();
     conn.setAutoCommit(true);
    }
   } catch (SQLException e1) {
    e1.printStackTrace();
   }
  }finally {
   try {
    if(stmt != null)
     stmt.close();
    if(conn != null)
     conn.close();
   } catch (SQLException e) {
    e.printStackTrace();
   }
  }  

 }

}

六、ScrollResultSet

代码如下:

import java.sql.*;

public class TestScroll {
 public static void main(String args[]) {

  try {
   new oracle.jdbc.driver.OracleDriver();
   String url = "jdbc:oracle:thin:@192.168.0.1:1521:SXT";
   Connection conn = DriverManager
     .getConnection(url, "scott", "tiger");
   Statement stmt = conn.createStatement(
     ResultSet.TYPE_SCROLL_INSENSITIVE,
     ResultSet.CONCUR_READ_ONLY);
   ResultSet rs = stmt
     .executeQuery("select * from emp order by sal");
   rs.next();
   System.out.println(rs.getInt(1));
   rs.last();
   System.out.println(rs.getString(1));
   System.out.println(rs.isLast());
   System.out.println(rs.isAfterLast());
   System.out.println(rs.getRow());
   rs.previous();
   System.out.println(rs.getString(1));
   rs.absolute(6);
   System.out.println(rs.getString(1));
   rs.close();
   stmt.close();
   conn.close();
  } catch (SQLException e) {
   e.printStackTrace();
  }
 }
}

七、UpdateResultSet

代码如下:

import java.sql.*;
public class TestUpdataRs {
    public static void main(String args[]){

 try{
     new oracle.jdbc.driver.OracleDriver();
     String url="jdbc:oracle:thin:@192.168.0.1:1521:SXT";
     Connection conn=DriverManager.getConnection(url,"scott","tiger");
     Statement stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);

     ResultSet rs=stmt.executeQuery("select * from emp2");

     rs.next();
     //更新一行数据
     rs.updateString("ename","AAAA");
     rs.updateRow();

     //插入新行
     rs.moveToInsertRow();
     rs.updateInt(1, 9999);
     rs.updateString("ename","AAAA");
     rs.updateInt("mgr", 7839);
     rs.updateDouble("sal", 99.99);
     rs.insertRow();
     //将光标移动到新建的行
     rs.moveToCurrentRow();

     //删除行
     rs.absolute(5);
     rs.deleteRow();

     //取消更新
     //rs.cancelRowUpdates();

   }catch(SQLException e){
     e.printStackTrace();
   }
    }
}


    
 
 

您可能感兴趣的文章:

  • java Servlet获取和设置cookie实例代码
  • 万般火急！关于java打印，已经得到printerJob实例，那么怎么通过它得到Pageable实例？
  • 可以有其他两个类的实例同时调用一个java实例的两个方法吗？
  • <java技术手册>与<java实例技术手册>这两本书怎么样?
  • Java单例模式实例简述
  • 寻求java加密算法及实例
  • java web start实例代码COPY不了,怎么办?
  • 请问哪里有《java实例技术手册》的电子书下载？100分赠送！
  • 请教：JAVA中说什么类的实例，那是怎么样的一个概念呢？
  • java实现大数加法(BigDecimal)的实例代码
  • Java究竟能干些什么呢?清高手们列举一些实例出来,跟帖有分.
  • java HashMap的keyset实例
  • java获取当前日期使用实例
  • java之super关键字用法实例解析
  • Java调用DOS实现定时关机的实例
  • java结束进程的实例代码
  • 急！大家谁有类似visio的java实例或代码？
  • java 如何获取对象实例的大小
  • 高分火速求解,请在线朋友回答:java自定义类怎样生成实例数组?( className[] N=new className[X];怎么不行?)
  • 刚学java想试编一个文本编辑器，各位能不能给推荐一些较好的参考程序或实例
  • Java位运算和逻辑运算的区别实例
    •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术，将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。












  • 相关文章推荐
  • java数据库连接池和数据库连接示例
  • Java连接池 Nanopool
  • Java连接池 Proxool
  • Java连接池 DBCP
  • 如何用java连接mysql数据库？
  • Java数据库连接池 BoneCP
  • 怎样用java调用DLL动态连接库？
  • Linux系统下利用java连接Oracle 10G
  • 请教：java中如何调用linux下的静态连接库.a文件？
  • java如何连接数据库？
  • 请教：java中如何调用linux下的静态连接库.a文件？
  • java连接DB2问题
  • java连接SQL SERVER
  • Java 连接池组件 JConnectionPool
  • oracle和Java的连接，急！！
  • 用java开发数据库，连接db2应该如何设置classpath (或者说应引入哪个包)
  • 在java中怎么连接MSSQL这样的数据库？database的属性里用什么驱动？
  • Java 和 Access数据库连接问题。谢谢！！
  • 请问JAVA怎么连接Sybase ASA 6.0 ？
  • 请问启动的多个java虚拟机如何共享一个连接池？
  • java命名空间java.sql类types的类成员方法: java_object定义及介绍
  • 我想学JAVA ,是买THINK IN JAVA 还是JAVA2核心技术:卷1 好???
  • java命名空间java.awt.datatransfer类dataflavor的类成员方法: imageflavor定义及介绍
  • 请问Java高手,Java的优势在那里？？,Java主要适合于开发哪类应用程序
  • java命名空间java.lang.management类managementfactory的类成员方法: getcompilationmxbean定义及介绍
  • 如何将java.util.Date转化为java.sql.Date?数据库中Date类型对应于java的哪个Date呢
  • java命名空间java.lang.management接口runtimemxbean的类成员方法: getlibrarypath定义及介绍
  • 谁有电子版的《Java编程思想第二版（Thinking in java second)》和《Java2编程详解（special edition java2)》？得到给分
  • java命名空间java.lang.management接口runtimemxbean的类成员方法: getstarttime定义及介绍
  • 本人想学java，请问java程序员的待遇如何，和java主要有几个比较强的方向
  • java命名空间java.awt.datatransfer类dataflavor的类成员方法: stringflavor定义及介绍


    • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除！

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3