JDBC

文章目录

什么是JDBC?

Java语言访问数据库的一种规范,是一套API

JDBC (Java Database Connectivity) API，即Java数据库编程接口，是一组标准的Java语言中的接口和类，使用这些接口和类，Java客户端程序可以访问各种不同类型的数据库。比如建立数据库连接、执行SQL语句进行数据的存取操作。
JDBC规范采用接口和实现分离的思想设计了Java数据库编程的框架。接口包含在java.sql及javax.sql包中，其中java.sql属于JavaSE，javax.sql属于JavaEE。这些接口的实现类叫做数据库驱动程序，由数据库的厂商或其它的厂商或个人提供。

为了使客户端程序独立于特定的数据库驱动程序，JDBC规范建议开发者使用基于接口的编程方式，即尽量使应用仅依赖java.sql及javax.sql中的接口和类。

JDBC驱动程序:

什么是JDBC驱动程序?
这些是各个数据库厂家根据JDBC的规范制作的JDBC实现类

JDBC驱动程序的四种类型:

  1. 第一种类型的驱动程序的实现是通过将JDBC的调用全部委托给其它编程接口来实现的，比如ODBC。这种类型的驱动程序需要安装本地代码库，即依赖于本地的程序，所以便携性较差。比如JDBC-ODBC桥驱动程序

  2. 第二种类型的驱动程序的实现是部分基于Java语言的。即该驱动程序一部分是用Java语言编写，其它部分委托本地的数据库的客户端代码来实现。同类型1的驱动一样，该类型的驱动程序也依赖本地的程序，所以便携性较差

  3. 第三种类型的驱动程序的实现是全部基于JAVA语言的。该类型的驱动程序通常由某个中间件服务器提供，这样客户端程序可以使用数据库无关的协议和中间件服务器进行通信，中间件服务器再将客户端的JDBC调用转发给数据库进行处理

  4. 第四种类型的驱动程序的实现是全部基于JAVA语言的。该类型的驱动程序中包含了特定数据库的访问协议，使得客户端可以直接和数据库进行通信

JDBC类结构:

                       DriverManager

  Driver                  			    Driver

  Connection                 		       Connection

  Statement                 				    Statement

  Resultset                       			      Resultset

DriverManager:这个是一个实现类,它是一个工厂类,用来生产Driver对象的
这个类的结构设计模式为工厂方法
Driver:这是驱动程序对象的接口,它指向一个实实在在的数据库驱动程序对象,那么这个数据库驱动程序对象是从哪里来的呢?
DriverManager工厂中有个方法:getDriver(String URL),通过这个方法可以得到驱动程序对象,这个方法是在各个数据库厂商按JDBC规范设计的数据库驱动程序包里的类中静态实现的,也就是在静态块中
Connection:这个接口可以制向一个数据库连接对象,那么如何得到这个连接对象呢?
是通过DriverManager工厂中的getConnection(String URL)方法得到的
Statement:用于执行静态的SQL语句的接口,通过Connection中的createStatement方法得到的
Resultset:用于指向结果集对象的接口,结果集对象是通过Statement中的execute等方法得到的

Java使用JDBC访问数据库的步骤:

  1. 得到数据库驱动程序 

  2. 创建数据库连接 

  3. 执行SQL语句 

  4. 得到结果集 

  5. 对结果集做相应的处理(增,删,改,查) 

  6. 关闭资源:这里释放的是DB中的资源

设置classpath:

  1. 在java文件中起的包名一定要是工程基目录下的子目录,classpath:基目录

  2. jar包,需要将这个.jar包的路径包括这个文件的全名添加到classpath中来

Oracle连接字符串的书写格式:

“oracle:jdbc:thin:@ip:1521: 数据库名”,”数据库用户名”,”数据库密码”

简单的例子:

package moudule1.first; 

import java.sql.*; 

public class FirstJdbc{ 
      public static void main(String[] args){
      
                 String sql="select * from yuchen_user";
                 Connection con=null;
                 Statement st=null;
                 ResultSet rs=null; 
       try 
       {  
       		     Class.forName("oracle.jdbc.driver.OracleDriver");
             	 con=DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:name", "scott","tiger");
                 st=con.createStatement();
                 rs=st.executeQuery(sql);
                 while(rs.next())
                 { 
                     System.out.println(rs.getInt("id"));
                     System.out.println(rs.getString("name"));

                 } 
       }catch(Exception e) 
       { 
                 e.printStackTrace(); 
       }finally 
       { 
	               try
                 {
                      con.close(); 
                 }catch(Exception e) 
                 {} 
                 try 
                 { 
                      st.close(); 
                 }catch(Exception e) 
                 { 
                 } 
                 try 
                 { 
                      rs.close();

                 }catch(Exception e) 
                 { 
                 }
 
       }     

      }
 
}

常用数据库的驱动程序及JDBC URL:

Oracle数据库:

驱动程序包名：ojdbc14.jar

 驱动类的名字：oracle.jdbc.driver.OracleDriver 
 
 JDBC URL：jdbc:oracle:thin:@dbip:port:databasename

 说明：驱动程序包名有可能会变

   JDBC URL中黑色字体部分必须原封不动的保留，为该驱动识别的URL格式。红色字体部分需要根据数据库的安装情况填写。其中各个部分含义如下：

    dbip –为数据库服务器的IP地址，如果是本地可写：localhost或127.0.0.1。

    port –为数据库的监听端口，需要看安装时的配置，缺省为1521。

    databasename –为数据库的SID，通常为全局数据库的名字。

    举例如果要访问本地的数据库allandb，端口1521，那么URL写法如下：

   jdbc:oracle:thin:@localhost:1521:allandb 下载地址如下:
   http://www.oracle.com/technology/software/tech/java/sqlj_jdbc/index.html

SQL Server数据库

   驱动程序包名：msbase.jar mssqlserver.jar msutil.jar

  驱动类的名字：com.microsoft.jdbc.sqlserver.SQLServerDriver

 JDBC URL：jdbc:microsoft:sqlserver://dbip:port;DatabaseName=databasename

   说明：驱动程序包名有可能会变

    JDBC URL中黑色字体部分必须原封不动的保留，为该驱动识别的URL格式。红色字体部需要根据数据库的安装情况填写。其中各个部分含义如下：

   dbip –为数据库服务器的IP地址，如果是本地可写：localhost或127.0.0.1。

    port –为数据库的监听端口，需要看安装时的配置，缺省为1433。

   databasename –数据库的名字。

   举例如果要访问本地的数据库allandb，端口1433，那么URL写法如下：

   jdbc: microsoft: sqlserver:@localhost:1433; DatabaseName =allandb

   下载地址：http://www.microsoft.com/downloads/details.aspx

MySQL数据库

驱动程序包名：mysql-connector-java-3.1.11-bin.jar

  驱动类的名字：com.mysql.jdbc.Driver

 JDBC URL：jdbc:mysql://dbip:port/databasename

  说明：驱动程序包名有可能会变

    JDBC URL中黑色字体部分必须原封不动的保留，为该驱动识别的URL格式。红色字体部需要根据数据库的安装情况填写。其中各个部分含义如下：

    dbip –为数据库服务器的IP地址，如果是本地可写：localhost或127.0.0.1。

    port –为数据库的监听端口，需要看安装时的配置，缺省为3306。

    databasename –数据库的名字。

    举例如果要访问本地的数据库allandb，端口1433，那么URL写法如下：

   jdbc:mysql://localhost:3306/allandb

下载地址：http://dev.mysql.com/downloads/connector/j/

Access数据库

驱动程序包名：该驱动程序包含在JavaSE中，不需要额外安装。

驱动类的名字：sun.jdbc.odbc.JdbcOdbcDriver

JDBC URL：jdbc:odbc:datasourcename

 说明：该驱动只能工作在Windows系统中，首先需要在操作系统中建立一个可以访问Access数据库的本地数据源(ODBC)，如果名字为allandb，那么URL写法如下：

    jdbc:odbc:allandb

PreparedStatement接口:

预编译的sql语句对象
作用: 解决了书写sql语句时一些特殊的字符与sql保留字符冲突的问题,非常方便

/**

*知识点:

*PreparedStatement接口及方法的使用

*程序目标:

*java文件:

*PreparedInsert.java:连接数据库,插入一条数据

*JdbcUtil.java:实现一个工具类,功能:1.连接数据库 2.关闭资源

*/

 

package moudule1.preparedstatement;
 
import java.sql.*; 
import moudule1.com.*; 

public class PreparedInsert{

      public static void main(String[] args) {

           String sql="insert into yuchen_user (id,name) values (?,?)";
           System.out.println(sql);
           Connection con=null;
           PreparedStatement ps=null;
           try{

                 con=JdbcUtil.getConnection();
                 ps=con.prepareStatement(sql);
                 
                 ps.setInt(1,2);
                 ps.setString(2,"zhangsan");
                 ps.executeUpdate();
                 ps.setInt(1,3);
                 ps.setString(2,"lisi");

           }catch(Exception e){

                 e.printStackTrace();

           }finally{

                 JdbcUtil.close(con,ps);

                 }

           }

      }

package moudule1.com;

 

import java.sql.*;

public class JdbcUtil{

      
      public static Connection getConnection() throws Exception{

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

       return DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:name", "scott","tiger");

           } 

      public static void close(Connection con,Statement st){
 
           close(con); 
           close(st); 
           } 

      public static void close(Connection con,Statement st,ResultSet rs){  

           close(con,st); 
           close(rs); 
           }
 

      public static void close(Connection con){

           try{ 
                 con.close();  
           }catch(Exception e){ 

                 }
           } 
           
      public static void close(Statement st){ 

           try{  
                 st.close(); 

           }catch(Exception e){ 
                 } 
           } 

      public static void close(ResultSet rs){
 
           try{  
                 rs.close(); 
           }catch(Exception e){ 
                 }  
           }  
      }

数据库的增删改查的例子:

/**

*知识点:

*JDBC+SQL+ORACLE

*程序目标:

*UserDao.java:实现了数据库的增删改查

*JdbcUtil.java:工具类,有连库和关闭资源的方法

*/

 

package moudule1.idus; 

import java.sql.*;
import moudule1.com.*;


public class UserDao{

      private String sql;
      private Connection con;
      private Statement st;
      private ResultSet rs;
   

      public UserDao(){
           sql=null;
           con=null;
           st=null;
           rs=null;
           }

     

      public void insert(){
    
           sql="insert into yuchen_user (id,name) values(";
           sql+="4,'zhouwu')";
           System.out.println(sql);

  
           try{
           con=JdbcUtil.getConnection();
           st=con.createStatement();
           st.executeUpdate(sql);


           }catch(Exception e){
                 e.printStackTrace();
           }finally{
                 JdbcUtil.close(con,st);
                 }
           }
          

      public void delete(){    
         
           sql="delete from yuchen_user where id=2";
           System.out.println(sql);
           try{
           
           con=JdbcUtil.getConnection();
            st=con.createStatement();
            st.executeUpdate(sql);
           }catch(Exception e){
                 e.printStackTrace();
           }finally{
                 JdbcUtil.close(con,st);
                 }

           }

          
      public void update(){

           sql="update yuchen_user set name='liumang' where id=1";
           System.out.println(sql);
           try{
                 con=JdbcUtil.getConnection();
            st=con.createStatement();
            st.executeUpdate(sql);
           }catch(Exception e){
                 e.printStackTrace();
           }finally{
                 JdbcUtil.close(con,st);
                 }
           }

          
      public void select(){
      
           sql="select * from yuchen_user";
           System.out.println(sql);
           try{
                 con=JdbcUtil.getConnection();
            st=con.createStatement();
             rs=st.executeQuery(sql);
            while(rs.next()){
               System.out.println(rs.getInt(1));
               System.out.println(rs.getString(2));
               }
           }catch(Exception e){ 
                 e.printStackTrace(); 
           }finally{ 
                 JdbcUtil.close(con,st,rs); 
                 } 
           } 
           
      public static void main(String[] args){ 
           UserDao ud=new UserDao();
           ud.select();
           ud.insert();
           ud.select();
           ud.update();
           ud.select();
           ud.delete();
           ud.select();

           }

      }

1.一些常用的方法:

/**

*知识点:

*execute方法,getResultSet(),getUpdateCount()

*程序目标:

*JdbcUtil.java:工具类,连接数据库,关闭资源

*sqlExecutor.java:命令行参数输入sql语句,并执行该语句

*/

package moudule1.fangfa;

 

import java.sql.*;
import moudule1.com.*;

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

          
           Connection con=null;
           Statement st=null;
           try{

               
                 con=JdbcUtil.getConnection();
                 st=con.createStatement();
                 boolean str=st.execute(args[0]);
                 if(str){
                      ResultSet rs=st.getResultSet();

                      while(rs.next()){
                     System.out.println(rs.getInt("id")+":"+rs.getString("name"));

                            }
                            rs.close();

                 }else{
                      int row=st.getUpdateCount();
                      System.out.println(row);
                      }
           }catch(Exception e){
                 e.printStackTrace();
           }finally{
                 JdbcUtil.close(con,st);
                 }

           }

      }

2. 补充

  JDBC连接MySQL

加载及注册JDBC驱动程序
Class.forName("com.mysql.jdbc.Driver");
Class.forName("com.mysql.jdbc.Driver").newInstance();

JDBC URL 定义驱动程序与数据源之间的连接
标准语法：
<protocol（主要通讯协议）>:<subprotocol（次要通讯协议，即驱动程序名称）>:<data source identifier（数据源）>

MySQL的JDBC URL格式：
jdbc:mysql//[hostname][:port]/[dbname][?param1=value1][&param2=value2]….

示例：jdbc:mysql://localhost:3306/sample_db?			
user=root&password=your_password

常见参数：

user 用户名

password 密码

autoReconnect 联机失败，是否重新联机（true/false）

maxReconnect 尝试重新联机次数

initialTimeout 尝试重新联机间隔

maxRows 传回最大行数

useUnicode 是否使用Unicode字体编码（true/false）

characterEncoding 何种编码（GB2312/UTF-8/…）

relaxAutocommit 是否自动提交（true/false）

capitalizeTypeNames 数据定义的名称以大写表示

 建立连接对象

String url="jdbc:mysql://localhost:3306/sample_db?
user=root&password=your_password";
Connection con = DriverManager.getConnection(url);

建立SQL陈述式对象（Statement Object）
Statement stmt = con.createStatement()；

执行SQL语句

executeQuery()
String query = "select * from test";
ResultSet rs=stmt.executeQuery(query);

结果集ResultSet
while(rs.next())
{rs.getString(1);rs.getInt(2);}

executeUpdate()
String upd="insert into test (id,name) values(1001,xuzhaori)";
int con=stmt.executeUpdate(upd);
execute()

示例：

try{
}
catch(SQLException sqle)
{
}
finally
{
}

PreparedStatement（预编语句）

PreparedStatement stmt = conn.prepareStatement("insert into 
test(id,name)values(?,?)");
stmt.setInt(1,id);
stmt.setString(2,name);
注：一旦设定语句的参数值后，就可以多次执行改语句，直到调用clearParameters（）方法将他清除为止

JNDI-数据源（Data Source）与连接池（Connection Pool）

Tomcat的JDBC数据源设置 技术手册P439

连接池工具－Proxool Var 0.8.3 技术手册P446

设置web.xml

<?xml version="1.0" encoding="ISO-8859-1"?>

<!--<?xml version="1.0" encoding="GB2312"?>-->

 

<web-app xmlns="http://java.sun.com/xml/ns/j2ee"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd"

version="2.4">

….

<servlet>

<servlet-name>ServletConfigurator</servlet-name>

<servlet-class>org.logicalcobwebs.proxool.configuration.ServletConfigurator</servlet-class>

 

<init-param>

<param-name>propertyFile</param-name>

<param-value>WEB-INF/classes/Proxool.properties</param-value>

</init-param>

<load-on-startup>1</load-on-startup>

</servlet>

后端统计端口添加下列

<servlet>

<servlet-name>Admin</servlet-name>

<servlet-class>org.logicalcobwebs.proxool.admin.servlet.AdminServlet</servlet-class>

</servlet>

 

<servlet-mapping>

<servlet-name>Admin</servlet-name>

<url-pattern>/Admin</url-pattern>

</servlet-mapping>

</web-app>

配置Proxool.properties

jdbc-0.proxool.alias=JSPBook

jdbc-0.proxool.driver-class=com.mysql.jdbc.Driver

jdbc-0.proxool.driver-url=jdbc:mysql://localhost:3306/sample_db?user=root&password=browser&useUnicode=true&characterEncoding=UTF-8

jdbc-0.proxool.maximum-connection-count=10

jdbc-0.proxool.prototype-count=4

jdbc-0.proxool.house-keeping-test-sql=select CURRENT_DATE

jdbc-0.proxool.verbose=true

jdbc-0.proxool.statistics=10s,1m,1d 后端统计接口添加此行

jdbc-0.proxool.statistics-log-level=DEBUG

使用Proxool连接池

Connection con = DriverManager.getConnection(“proxool.JSPBook”);

Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE);

String query = “SELECT * FROM employee”;

ResultSet rs = stmt.executeQuery(query);

# java # 数据库
Logo
CSDN学习社区

CSDN联合极客时间，共同打造面向开发者的精品内容学习社区，助力成长！

更多推荐

嵌入式作业（七）：基于Ardunio的STM32串口通信

嵌入式作业（七）0作业要求1Ardunio 完成STM32的串口通信（1）安装Ardunio IDE（2）stm32串口通信2关于 stduino IDE0作业要求安装 Ardunio IDE 和相关软件支持库，在Ardunio 完成STM32板子的串口通信程序：（1）持续向串口输出“Hello world！”；（2）当接收到“stop!”时，停止输出。网上有一个国人版的MCU集成开发平台， st

avatar CSDN学习社区

“模式识别与机器学习”学习笔记no2.再谈感知机

接**上篇：上篇主要进行了PLA，Pocket算法的理论过程分析和在给定数据集上利用pocket算法对数据集进行分类学习，得到错分数量最少的分类面。上篇中pocket算法的过程已经进行了编程和测试，框架已经建立了起来，这一篇主要上篇中没有提到或涉及不深的几个问题。1.数据集的构造。上篇是直接使用了题目给的向量，这次来根据正态分布来产生数据集。np.random.normal函数可以根据均值和方差生

avatar CSDN学习社区

浅谈我对机器学习的理解

算算时间，从开始到现在，做机器学习算法也将近八个月了。虽然还没有达到融会贯通的地步，但至少在熟悉了算法的流程后，我在算法的选择和创造能力上有了不小的提升。实话说，机器学习很难，非常难，要做到完全了解算法的流程、特点、实现方法，并在正确的数据面前选择正确的方法再进行优化得到最优效果，我觉得没有个八年十年的刻苦钻研是不可能的事情。其实整个人工智能范畴都属于科研难题，包括模式识别、...

avatar CSDN学习社区