20JAVA数据库操作

Posted 2021-12-01 aha-best

JAVA数据库操作

 

JDBC

---

JDBC(Java Database Connectivity，Java数据库连接)是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一的访问接口。JDBC由一组用Java语言编写的类与接口组成，通过调用这些类和接口所提供的方法，用户能够以一致的方式连接多种不同的数据库系统(如Access、Server 2000、Oracle、Sybase等)，进而使用标准的SQL语言来存取数据库中的数据，而不必再为每一种数据库系统编写不同的Java程序代码。

JDBC的种类

l  JDBC-ODBC桥

第1类驱动程序用于连接JDBC和另一种数据库连接机制ODBC，JDBC-ODBC桥使基于JDBC的程序能通过传统的ODBC驱动程序访问数据库。由于大多数数据库系统都带有ODBC驱动程序，所以Java程序能访问诸如Oracle、Sybase、MS SQL Server和MS Access等数据库。这一驱动程序已被包括在Java 2 SDK的sun.jdbc.odbc包中。当然，使用JDBC-ODBC桥访问数据库的服务器还需在本地安装ODBC类库、驱动程序及其他辅助文件。

l  Java到本地API

第2类JDBC驱动程序使用Java本地接口(Java Native Interfce)向本地的数据库API发送指令。第2类驱动程序的速度往往高于JDBC-ODBc桥，它也要求在本地安装连接目标数据库的类库。

l  Java到网络协议

第3类驱动程序是纯Java的驱动程序，它通过—定的网络协议与数据库服务器上的JDBC中间件(Middleware)通信。这一中间件程序将网络协议指令转换成数据库指令。第3类驱动程序是最灵活的JDBC方案，因为它不要求在访问数据库的Java程序所在个地端安装目标数据库的类库，使该程序可通过网络协议与不同的数据库通信。

l  Java到数据库协议

       第4类驱动程序也是纯Java的，它通过实现一定的数据库协议(如 oracle公司的SQL*Net)直接与数据库通信。和第3类驱动程序一样，它直接与数据库通信，所以其效率是4种驱动程序中最高的。其缺点是：当目标数据库的类型更换时，必须重新购买JDBC驱动程序，并在本地安装。

究竟选择哪一类型的驱动程序，完全取决于所构建网站的特别需求。如果个希望在程序本地端安装大量目标数据库的类库，则应该考虑后两种驱动程序；如果后两种驱动程序的价格特别高，那么可以便用第1、2类驱动程序，因为它们往往是免费的。当然，性能和灵活性也是较难求全的两个因素，需要仔细权衡。

JDBC URL

        JDBC URL提供了一种标识数据库的方法，可以使相应的驱动程序能够识别该数据库并与它建立连接。标准的JDBC URL的格式如下：

     jdbc : <子协议名> : <子名称>

        JDBC URL由三个部分组成，各个部分之间用冒号分隔。<子协议>是指数据库连接的方式。<子名称>可以根据子协议的改变而变化。

JDBC-ODBC桥驱动程序使用odbc子协议。该子协议的URL格式如下：

jdbc:odbc:<data_source_name>[<attribute_name1>=<attribute_value1>] ……

[<attribute_namen>=<attribute_valuen>]

其中：data_source_name指本地ODBC数据源(建立数据源的方法详见下一节)的名字。例如下列形式的JDBC URL：

jdbc:odbc:mydb;user=me;pwd=pass

该JDBC URL表示本地odbc数据源的名字为mydb，该数据源的用户名为me，数据源的口令为pass。注意，当数据库为不具有服务器功能的本地数据库(如Microsoft Access97/2000)时，数据源的用户名与口令是与数据库系统所拥有的用户名与口令是无关的。

如果是其他的数据库，那么请参考对应数据库厂商的API文档。另外，对于Oracle，它的thin连结方式的url是：

jdbc:oracle:thin:@serverName:portNumber:dataInstance

其中，oracle为子协议名称，thin是oracle数据库的一种连结方式，“serverName”为Oracle数据库服务器名称，可以是一个域名，也可以是IP地址，而“portNumber”为Oracle数据库使用的端口号，默认为1521，如果你在安装Oracle数据库的时候没有去修改它，那么你就是用1521就可以了，而“dataInstance”是数据库的实例名，根据情况使用。

本书使用的Oracle数据库版本为Oracle9i，但读者完全可以使用Oracle8i/Oracle 10g的版本来完成对应的试验。

 

在前面说过，JDBC的设计目标之一就是让它成为一个公共的接口，对于不同的数据库，我们只需要修改对应的驱动就可以了，而不需要去修改对应的SQL语句。所以，本书将主要以Oracle一种数据库为例子来论述JDBC的特征、用法。另外，因为对于JDBC-ODBC桥来说，稍微有点特殊，它需要设置ODBC数据源，所以我们在此也特别提出来讲述，主要是介绍如何设置ODBC数据源的（以Access数据库为例），如果读者有过ODBC编程的经验，或者对此中模式不感兴趣，读者可以跳过下一节的内容，它不会影响你对整个JDBC编程方式的理解。

2.1.6 手动建立ODBC数据源

后面程序中，我们要以实例来说明JDBC的使用，所以首先我们以Window2000为例，建立一个ODBC数据源，以便于以后的讲解和使用。下面以连接Access数据库student.mdb为例说明建立ODBC数据源的使用方法。这里的操作画面是以Windows 200操作系统为例进行说明的，Windows 98/NT/XP操作系统与此类似。

l  进入ODBC数据源环境

        打开Windows2000系统中的控制面板，找到“管理工具”，进入管理工具中选择“数据源(ODBC)”图标，选择“用户 DSN”选项卡，出现如图2-2所示画面。画面中显示了已有的数据源名称。

                       

图2-2  用户数据源对话框

提示：

       在这里也可以选择“系统DSN”选项卡。“系统DSN”和“用户DSN”在使用上的区别在于：“用户DSN”上设置的DSN只能在使用进行设置操作的用户名登录的时候，才可以使用；而“系统DSN”则针对任何登录的用户都可以使用。

l  创建新的数据源

在图2-2所示的画面中，单击“添加”按钮出现选择列表。此时选择“Microsoft Access Driver(*.mdb)”作为新数据源的驱动程序，单击“完成”按钮，出现如图2-3所示的画面。

 

图2-3  输入数据源名称

l  为新数据源命名，并与指定的数据库关联

在图2-3中的数据源名文本框里为数据源命名，这里输入的是NIT-Pro。为了使这个数据源与某个数据库关联，此时单击“选择”按钮，出现如图2-4所示画面。选择某驱动器下、某个目录下的数据库即可。这里选择C:\JavaWeb\student.mdb数据库。单击“确定”按钮，又回到图11-4所示的画面。

 

图2-4 指定数据库

l  设置用户的登录名称和密码

       如果用户需要为数据源“NIT-Pro”设置一个登录名称和密码，就单击图2-3中的“高级”按钮，否则单击“确定”按钮以完成数据源设置的全部操作。

       单击“高级”按钮后，出现如图2-5所示画面。

 

图2-5  设置登录名称与密码

       在登录名称文本框里输入一个用户名，这里输入你自己想要使用的用户名；在密码文本框里输入密码，然后单击“确定”按钮，又回到图2-2所示的画面，再单击“确定”按钮就完成了数据源设置的全部操作。

       设置好Access数据库的数据源之后，这个数据源NIT-Pro就对应着一个Access数据库，即student.mdb。用户在编写Java程序时，就可以将这个数据源作为数据库的连接对象包含在源程序中，以便对存储在数据库中的数据进行存取操作。

       需要说明的是，对于不同类型的数据库，在建立ODBC数据源时，根据选择的数据库驱动程序的不同，数据源的设置画面也会不相同。请读者参考Access数据源设置方法自行设置。

2.1.7 设置和Oracle相关的环境

l  设置Oracle驱动的类路径

在使用Oracle数据库的时候，需要使用它所提供的驱动，在安装完Oracle数据库后，可以在它的安装路径下找到，对于Oracle9i（Oracle8i也类似），可以在<安装目录>/ora92/jdbc/lib目录下，找到一个classes12.zip（或者classes12.jar），将它加入到环境变量CLASSPATH中去就可以了。

l  建立数据库表和初始化数据

在本书中，我们假设使用的Oracle数据库实例名称为O9I，使用下面的SQL语句创建一个用于存储“学生信息”的表，并且初始化了两笔数据：

create table students (student_id varchar2(20) primary key,

     student_name varchar2(20) not null,

     student_age integer not null,

     student_sex char(1) not null

)

 

insert into students values(‘Eng001‘,‘Diana‘,23,‘F‘);

insert into students values(‘Cas001‘,‘Alex‘,30,‘M‘);

因为本书的重点不在论述Oracle的使用，所以，关于如何在Oracle中创建表格、如何使用SQLPlus等，都不在本书的讨论范围，请读者参考相关的资料。

l  设置Tomcat环境

如果需要在JSP/Servlet中使用Oracle的JDBC驱动，那么需要将<安装目录>/ora92/jdbc/lib目录下的classes12.jar文件拷贝到<tomcat安装目录>/common/lib目录下，这样，就可以在JSP/Servlet中使用Oracle的JDBC驱动了。

SQL数据类型	Java数据类型	对应方法
integer/int	int	getInt()
Smallint	short	getShort()
float(n)	double	getDouble()
Double	double	getDouble()
Real	float	getFloat()
varchar(n)	java.lang.String	getString()
character(n)/char(n)	java.lang.String	getString()
Boolean	boolean	getBoolean()
Date	java.sql.Date	getDate()
Time	java.sql.Time	getTime()
Blob	java.sql.Blob	getBlob()
Clob	java.sql.Clob	getClob()
Array	java.sql.Array	getArray()

 

JAVA数据库操作

Microsoft SQL Server

连接数据库

package com.Aha.Best;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

public class JAVAConnMSS {

    public static void main(String[] args) {

       try {

           Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

           System.out.println("驱动加载成功");

       } catch (ClassNotFoundException e) {

           System.out.println("驱动加载失败");

           e.printStackTrace();

       }

       try {

           Connection conn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;DatabaseName=MyDataBase","sa","zl225226");

           System.out.println("数据库连接成功");

       } catch (SQLException e) {

           System.out.println("数据库连接失败");

           e.printStackTrace();

       }

    }

}

数据库查询

package com.Aha.Best;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

public class JAVASelectMSS {

    public static void main(String[] args) {

       try {

           Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

           System.out.println("驱动加载成功");

       } catch (ClassNotFoundException e) {

           System.out.println("驱动加载失败");

           e.printStackTrace();

       }

       try {

           Connection conn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;DatabaseName=MyDataBase","sa","zl225226");

           System.out.println("数据库连接成功");

           String sql = "select * from ADR_PROV";

           PreparedStatement ps = conn.prepareStatement(sql);

           ResultSet rs = ps.executeQuery();

           while(rs.next()){

              int id = rs.getInt("PROV_ID");

                String name = rs.getString("Name");                                                                                                                                                  ;

                System.out.println("省号："+id+" "+"名称："+name);

           }

           if(rs != null){

              rs.close();

              System.out.println("查询结果完成");

           }

           if(ps != null){

              ps.close();

              System.out.println("关闭查询语句");

           }

           if(conn != null){

              conn.close();

              System.out.println("关闭数据库连接");

           }

       } catch (SQLException e) {

           System.out.println("数据库连接失败");

           e.printStackTrace();

       }

    }

}

数据库更新

package com.Aha.Best;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

public class JAVAIUDMSS {

    public static void main(String[] args) {

       try {

           Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

           System.out.println("驱动加载成功");

       } catch (ClassNotFoundException e) {

           System.out.println("驱动加载失败");

           e.printStackTrace();

       }

       try {

           Connection conn = DriverManager.getConnection("jdbc:sqlserver://localhost:1433;DatabaseName=MyDataBase","sa","zl225226");

           System.out.println("数据库连接成功");

           Statement st = conn.createStatement();

           //String sql = "insert into ADR_PROV(PROV_ID,name) values(930000,‘意大利‘);insert into ADR_PROV(PROV_ID,name) values(940000,‘俄罗斯‘);";

           //String sql ="update ADR_PROV set PROV_ID = right(PROV_ID,5) where Prov_ID like ‘9%‘";

           String sql = "delete ADR_prov where len(PROV_ID) = 5";

           int num = st.executeUpdate(sql);

           System.out.println("受影响的"+num+"行");

           if(st != null){

              st.close();

              System.out.println("更新语句完成");

           }

           if(conn != null){

              conn.close();

              System.out.println("关闭数据库连接");

           }

       } catch (SQLException e) {

           System.out.println("数据库连接失败");

           e.printStackTrace();

       }

    }

}

Oracle Database

连接数据库

package com.Aha.Best;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

public class JAVAConnOracle {

    public static void main(String[] args) {

       try {

           Class.forName("oracle.jdbc.driver.OracleDriver");

           System.out.println("驱动加载成功");

       } catch (ClassNotFoundException e) {

           System.out.println("驱动加载失败");

           e.printStackTrace();

       }

       try {

           Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:orcl","sys as sysdba","orcl");

           System.out.println("数据库连接成功");

       } catch (SQLException e) {

           System.out.println("数据库连接失败");

           e.printStackTrace();

       }

    }

}

mysql

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

public class MySqlJDBC {

    public static void main(String[] args) {

       Connection conn = null;

       Statement st = null;

       ResultSet rs = null;

       String url = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC&characterEncoding=utf8&useUnicode=true&useSSL=false";

       String user = "root";

       String password = "123456";

       try {

           Class.forName("com.mysql.cj.jdbc.Driver");

           System.out.println("驱动加载成功");

           conn = DriverManager.getConnection(url, user, password);

           System.out.println("连接数据库成功");

           st = conn.createStatement();

           System.out.println("进入状态");

           String sql = "select * from student;";

           rs = st.executeQuery(sql);

           while(rs.next()){

              System.out.println(rs.getInt(1)+" "+rs.getString(2)+" "+rs.getInt(3));

           }

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

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

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

       } catch (ClassNotFoundException e) {

           e.printStackTrace();

       } catch (SQLException e) {

           e.printStackTrace();

       }

    }

}