利用JDBC连接Oracle数据库(转)

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了利用JDBC连接Oracle数据库(转)相关的知识,希望对你有一定的参考价值。

http://blog.csdn.net/wahaha1_/article/details/8512438

 

  1. JDBC是Sun公司制定的一个可以用Java语言连接数据库的技术。  
  2.   
  3. 一、JDBC基础知识          
  4.   
  5.         JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。JDBC为数据库开发人员提供了一个标准的API,据此可以构建更高级的工具和接口,使数据库开发人员能够用纯 Java API 编写数据库应用程序,并且可跨平台运行,并且不受数据库供应商的限制。  
  6.   
  7. 1、跨平台运行:这是继承了Java语言的“一次编译,到处运行”的特点;  
  8.   
  9. 2、不受数据库供应商的限制:巧妙在于JDBC设有两种接口,一个是面向应用程序层,其作用是使得开发人员通过SQL调用数据库和处理结果,而不需要考虑数据库的提供商;另一个是驱动程序层,处理与具体驱动程序的交互,JDBC驱动程序可以利用JDBC API创建Java程序和数据源之间的桥梁。应用程序只需要编写一次,便可以移到各种驱动程序上运行。Sun提供了一个驱动管理器,数据库供应商——如mysql、Oracle,提供的驱动程序满足驱动管理器的要求就可以被识别,就可以正常工作。所以JDBC不受数据库供应商的限制。  
  10.   
  11.   
  12.   
  13.   
  14.         JDBC API可以作为连接Java应用程序与各种关系数据库的纽带,在带来方便的同时也有负面影响,以下是JDBC的优、缺点。优点如下:  
  15.   
  16.   
  17. 操作便捷:JDBC使得开发人员不需要再使用复杂的驱动器调用命令和函数;  
  18. 可移植性强:JDBC支持不同的关系数据库,所以可以使同一个应用程序支持多个数据库的访问,只要加载相应的驱动程序即可;  
  19. 通用性好:JDBC-ODBC桥接驱动器将JDBC函数换成ODBC;  
  20. 面向对象:可以将常用的JDBC数据库连接封装成一个类,在使用的时候直接调用即可。  
  21.   
  22.         缺点如下:  
  23.   
  24.   
  25. 访问数据记录的速度受到一定程度的影响;  
  26. 更改数据源困难:JDBC可支持多种数据库,各种数据库之间的操作必有不同,这就给更改数据源带来了很大的麻烦  
  27.   
  28.   
  29.   
  30.   
  31. 二、JDBC连接数据库的流程及其原理  
  32.   
  33. 1、在开发环境中加载指定数据库的驱动程序。例如,接下来的实验中,使用的数据库是Oracle,所以需要去下载Oracle支持JDBC的驱动程序(其实这个地方并不需要去官网上下载jdbc驱动,本地安装的Oracle中就有,是一个ojdbc14.jar的文件);而开发环境是MyEclipse,将下载得到的驱动程序加载进开发环境中(具体示例的时候会讲解如何加载)。  
  34.   
  35.   
  36.   
  37.   
  38. 2、在Java程序中加载驱动程序。在Java程序中,可以通过 “Class.forName(“指定数据库的驱动程序”)” 方式来加载添加到开发环境中的驱动程序,例如加载Oracle的数据驱动程序的代码为:  Class.forName(“oracle.jdbc.driver.OracleDriver”)  
  39.   
  40.   
  41.   
  42.   
  43. 3、创建数据连接对象:通过DriverManager类创建数据库连接对象Connection。DriverManager类作用于Java程序和JDBC驱动程序之间,用于检查所加载的驱动程序是否可以建立连接,然后通过它的getConnection方法,根据数据库的URL、用户名和密码,创建一个JDBC Connection 对象。如:Connection connection =  DriverManager.geiConnection(“连接数据库的URL", "用户名", "密码”)。其中,URL=协议名+IP地址(域名)+端口+数据库名称;用户名和密码是指登录数据库时所使用的用户名和密码。具体示例创建Oracle的数据库连接代码如下:  
  44.   
  45.               conn=DriverManager.getConnection(url, user, password);  
  46.   
  47.   
  48.   
  49.   
  50.   
  51. 4、创建Statement对象:Statement 类的主要是用于执行静态 SQL 语句并返回它所生成结果的对象。通过Connection 对象的 createStatement()方法可以创建一个Statement对象。例如:Statement statament = connection.createStatement(); 具体示例创建Statement对象代码如下:  
  52.   
  53.              Statement statamentMySQL =connectMySQL.createStatement();   
  54.   
  55.   
  56.   
  57.   
  58.   
  59. 5、调用Statement对象的相关方法执行相对应的 SQL 语句:通过execuUpdate()方法用来数据的更新,包括插入和删除等操作,例如向staff表中插入一条数据的代码:  
  60.   
  61.        statement.excuteUpdate( "INSERT INTO staff(name, age, sex,address, depart, worklen,wage)" + " VALUES (‘Tom1‘, 321, ‘M‘, ‘china‘,‘Personnel‘,‘3‘,‘3000‘ ) ") ;   
  62.   
  63. 通过调用Statement对象的executeQuery()方法进行数据的查询,而查询结果会得到 ResulSet对象,ResulSet表示执行查询数据库后返回的数据的集合,ResulSet对象具有可以指向当前数据行的指针。通过该对象的next()方法,使得指针指向下一行,然后将数据以列号或者字段名取出。如果当next()方法返回null,则表示下一行中没有数据存在。使用示例代码如下:  
  64.   
  65.        ResultSet resultSel = statement.executeQuery( "select * from staff" );  
  66.   
  67.   
  68.   
  69.   
  70. 6、关闭数据库连接:使用完数据库或者不需要访问数据库时,通过Connection的close() 方法及时关闭数据连接。  
  71.   
  72.   
  73.   
  74.   
  75. 三、JDBC应用示例实验  
  76.   
  77. 实验 步骤:  
  78. S1、下载ojdbc14.jar驱动文件,并将该文件放到你的项目中去;   
  79. S2、在MyEclipse中的项目中添加Oracle驱动程序:在项目名上右键-> Build Path ->Add External Archiver然后选择你刚才放在项目中的文件, 点确定即可。  
  80. S3、打开Oracle的各项服务,并在Oracle中建一张表。  
  81. S4、编写MyEclipse与Oracle的连接程序:  
  82. [cpp] view plaincopyprint?<SPAN style="FONT-SIZE: 16px">import java.sql.Connection;    
  83. import java.sql.DriverManager;    
  84. import java.sql.PreparedStatement;    
  85. import java.sql.ResultSet;    
  86. import java.sql.Statement;    
  87. import java.sql.* ;    
  88.     
  89. public class JDBC_Test {    
  90.     //orcl为oracle数据库中的数据库名,localhost表示连接本机的oracle数据库     
  91.    //1521为连接的端口号     
  92.     private static String url="jdbc:oracle:thin:@localhost:1521:orcl";    
  93.     //system为登陆oracle数据库的用户名     
  94.     private static String user="system";    
  95.     //manager为用户名system的密码     
  96.     private static String password="manager";    
  97.     public static Connection conn;    
  98.     public static PreparedStatement ps;    
  99.     public static ResultSet rs;    
  100.     public static Statement st ;    
  101.     //连接数据库的方法     
  102.     public void getConnection(){    
  103.         try {    
  104.             //初始化驱动包     
  105.             Class.forName("oracle.jdbc.driver.OracleDriver");    
  106.             //根据数据库连接字符,名称,密码给conn赋值     
  107.             conn=DriverManager.getConnection(url, user, password);    
  108.                 
  109.         } catch (Exception e) {    
  110.             // TODO: handle exception     
  111.             e.printStackTrace();    
  112.         }    
  113.     }    
  114.      //测试能否与oracle数据库连接成功     
  115.      public static void main(String[] args) {    
  116.         JDBC_Test basedao=new JDBC_Test();    
  117.         basedao.getConnection();    
  118.         if(conn==null){    
  119.             System.out.println("与oracle数据库连接失败!");    
  120.         }else{    
  121.             System.out.println("与oracle数据库连接成功!");    
  122.         }    
  123.      }    
  124. }    
  125. </SPAN>    
  126.   
  127. import java.sql.Connection;  
  128. import java.sql.DriverManager;  
  129. import java.sql.PreparedStatement;  
  130. import java.sql.ResultSet;  
  131. import java.sql.Statement;  
  132. import java.sql.* ;  
  133.   
  134. public class JDBC_Test {  
  135.     //orcl为oracle数据库中的数据库名,localhost表示连接本机的oracle数据库  
  136.    //1521为连接的端口号  
  137.     private static String url="jdbc:oracle:thin:@localhost:1521:orcl";  
  138.     //system为登陆oracle数据库的用户名  
  139.     private static String user="system";  
  140.     //manager为用户名system的密码  
  141.     private static String password="manager";  
  142.     public static Connection conn;  
  143.     public static PreparedStatement ps;  
  144.     public static ResultSet rs;  
  145.     public static Statement st ;  
  146.     //连接数据库的方法  
  147.     public void getConnection(){  
  148.         try {  
  149.             //初始化驱动包  
  150.             Class.forName("oracle.jdbc.driver.OracleDriver");  
  151.             //根据数据库连接字符,名称,密码给conn赋值  
  152.             conn=DriverManager.getConnection(url, user, password);  
  153.               
  154.         } catch (Exception e) {  
  155.             // TODO: handle exception  
  156.             e.printStackTrace();  
  157.         }  
  158.     }  
  159.      //测试能否与oracle数据库连接成功  
  160.      public static void main(String[] args) {  
  161.         JDBC_Test basedao=new JDBC_Test();  
  162.         basedao.getConnection();  
  163.         if(conn==null){  
  164.             System.out.println("与oracle数据库连接失败!");  
  165.         }else{  
  166.             System.out.println("与oracle数据库连接成功!");  
  167.         }  
  168.      }  
  169. }  
  170.   
  171. S5、如果上述的连接已经建立,就可以利用JDBC中的Java API对数据库进行操作了,具体的查询,插入,删除,更新操作如下:  
  172. [cpp] view plaincopyprint?<SPAN style="FONT-SIZE: 16px">代码转载自:http://blog.csdn.net/cxwen78/article/details/6863696     
  173.     
  174. import java.sql.Connection;    
  175. import java.sql.DriverManager;    
  176. import java.sql.ResultSet;    
  177. import java.sql.SQLException;    
  178. import java.sql.Statement;    
  179.     
  180. public class JDBC_Test {    
  181.     // 创建静态全局变量     
  182.     static Connection conn;    
  183.     
  184.     static Statement st;    
  185.     
  186.     public static void main(String[] args) {    
  187.         insert();   //插入添加记录     
  188.         update();   //更新记录数据     
  189.         delete();   //删除记录     
  190.         query();    //查询记录并显示     
  191.     }    
  192.         
  193.     /* 插入数据记录,并输出插入的数据记录数*/    
  194.     public static void insert() {    
  195.             
  196.         conn = getConnection(); // 首先要获取连接,即连接到数据库     
  197.     
  198.         try {    
  199.             String sql = "INSERT INTO staff(name, age, sex,address, depart, worklen,wage)"    
  200.                     + " VALUES (‘Tom1‘, 32, ‘M‘, ‘china‘,‘Personnel‘,‘3‘,‘3000‘)";  // 插入数据的sql语句     
  201.                 
  202.             st = (Statement) conn.createStatement();    // 创建用于执行静态sql语句的Statement对象     
  203.                 
  204.             int count = st.executeUpdate(sql);  // 执行插入操作的sql语句,并返回插入数据的个数     
  205.                 
  206.             System.out.println("向staff表中插入 " + count + " 条数据"); //输出插入操作的处理结果     
  207.                 
  208.             conn.close();   //关闭数据库连接     
  209.                 
  210.         } catch (SQLException e) {    
  211.             System.out.println("插入数据失败" + e.getMessage());    
  212.         }    
  213.     }    
  214.         
  215.     /* 更新符合要求的记录,并返回更新的记录数目*/    
  216.     public static void update() {    
  217.         conn = getConnection(); //同样先要获取连接,即连接到数据库     
  218.         try {    
  219.             String sql = "update staff set wage=‘2200‘ where name = ‘lucy‘";// 更新数据的sql语句     
  220.                 
  221.             st = (Statement) conn.createStatement();    //创建用于执行静态sql语句的Statement对象,st属局部变量     
  222.                 
  223.             int count = st.executeUpdate(sql);// 执行更新操作的sql语句,返回更新数据的个数     
  224.                 
  225.             System.out.println("staff表中更新 " + count + " 条数据");      //输出更新操作的处理结果     
  226.                 
  227.             conn.close();   //关闭数据库连接     
  228.                 
  229.         } catch (SQLException e) {    
  230.             System.out.println("更新数据失败");    
  231.         }    
  232.     }    
  233.     
  234.     /* 查询数据库,输出符合要求的记录的情况*/    
  235.     public static void query() {    
  236.             
  237.         conn = getConnection(); //同样先要获取连接,即连接到数据库     
  238.         try {    
  239.             String sql = "select * from staff";     // 查询数据的sql语句     
  240.             st = (Statement) conn.createStatement();    //创建用于执行静态sql语句的Statement对象,st属局部变量     
  241.                 
  242.             ResultSet rs = st.executeQuery(sql);    //执行sql查询语句,返回查询数据的结果集     
  243.             System.out.println("最后的查询结果为:");    
  244.             while (rs.next()) { // 判断是否还有下一个数据     
  245.                     
  246.                 // 根据字段名获取相应的值     
  247.                 String name = rs.getString("name");    
  248.                 int age = rs.getInt("age");    
  249.                 String sex = rs.getString("sex");    
  250.                 String address = rs.getString("address");    
  251.                 String depart = rs.getString("depart");    
  252.                 String worklen = rs.getString("worklen");    
  253.                 String wage = rs.getString("wage");    
  254.                     
  255.                 //输出查到的记录的各个字段的值     
  256.                 System.out.println(name + " " + age + " " + sex + " " + address    
  257.                         + " " + depart + " " + worklen + " " + wage);    
  258.                 
  259.             }    
  260.             conn.close();   //关闭数据库连接     
  261.                 
  262.         } catch (SQLException e) {    
  263.             System.out.println("查询数据失败");    
  264.         }    
  265.     }    
  266.     
  267.     /* 删除符合要求的记录,输出情况*/    
  268.     public static void delete() {    
  269.     
  270.         conn = getConnection(); //同样先要获取连接,即连接到数据库     
  271.         try {    
  272.             String sql = "delete from staff  where name = ‘lili‘";// 删除数据的sql语句     
  273.             st = (Statement) conn.createStatement();    //创建用于执行静态sql语句的Statement对象,st属局部变量     
  274.                 
  275.             int count = st.executeUpdate(sql);// 执行sql删除语句,返回删除数据的数量     
  276.                 
  277.             System.out.println("staff表中删除 " + count + " 条数据\n");    //输出删除操作的处理结果     
  278.                 
  279.             conn.close();   //关闭数据库连接     
  280.                 
  281.         } catch (SQLException e) {    
  282.             System.out.println("删除数据失败");    
  283.         }    
  284.             
  285.     }    
  286.         
  287.     /* 获取数据库连接的函数*/    
  288.     public static Connection getConnection() {    
  289.         Connection con = null;  //创建用于连接数据库的Connection对象     
  290.         try {    
  291.             Class.forName("com.mysql.jdbc.Driver");// 加载Mysql数据驱动     
  292.                 
  293.             con = DriverManager.getConnection(    
  294.                     "jdbc:mysql://localhost:3306/myuser", "root", "root");// 创建数据连接    
  295.                 
  296.         } catch (Exception e) {    
  297.             System.out.println("数据库连接失败" + e.getMessage());    
  298.         }    
  299.         return con; //返回所建立的数据库连接     
  300.     }    
  301. }    
  302. </SPAN>  

以上是关于利用JDBC连接Oracle数据库(转)的主要内容,如果未能解决你的问题,请参考以下文章

怎样利用JDBC连接并操作Oracle数据库

(转)jdbc:oracle:thin:@192.168.3.98:1521:orcl(详解)

JDBC 连接Oracle

JDBC 连接Oracle

jdbc连接数据库使用sid和service_name的区别(转)

(转)Tomcat数据源连接池加密