JDBC个人学习总结

最新推荐文章于 2024-06-21 14:47:54 发布
最新推荐文章于 2024-06-21 14:47:54 发布
阅读量4.5k 收藏 2
点赞数 2
分类专栏： JAVAweb基础 # JAVA数据库连接 文章标签： java mysql jdbc
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/JAVA_php_Jack/article/details/104705096
版权

JDBC个人学习总结

JDBC是什么

JDBC：JAVA Database Connectivity，是用于在Java编程语言和广泛的数据库之间独立于数据库的连接的标准Java API，是JAVA用来与各种数据库连接的。

JDBC库包含用于下面提到的每个任务的API，这些API通常与数据库使用相关联：

  • 与数据库建立连接。
  • 创建SQL语句。
  • 在数据库中执行SQL操作。
  • 查看和修改结果记录。

总的来说，JDBC可以为多种关系型数据库DMS提供统一的访问方式，即用JAVA来操作数据库，为Java程序员操作数据提供了方法。
JDBC API使用驱动程序管理器和特定于数据库的驱动程序来提供与不同的数据库之间的透明连接。如图：
在这里插入图片描述
其中java.sql和javax.sql是JDBC 4.0的主要软件包，一般我们在开发过程中主要用的java.sql，大家如果想避免导错包的话，可以直接在自己的Java代码上先直接加上import java.sql.*（后面会提到）。

JDBC API

JDBC API支持用于数据库访问的两层和三层处理模型，但是通常，JDBC体系结构由两层组成：

  • JDBC API：这提供了应用程序到JDBC管理器的连接。
  • JDBC Driver API：它支持JDBC管理器到驱动程序的连接。

JDBC驱动程序管理器确保使用正确的驱动程序来访问每个数据源。驱动程序管理器能够支持连接到多个异构数据库的多个并发驱动程序。

总结：
在这里插入图片描述

  1. JDBC API 的主要功能是提供工作操作访问接口：Connection、Statement（PreparedStatement）、CallableStatement、ResultSet。
  2. JDBC DriverManager：管理不同的数据库驱动
  3. 各种数据库驱动：相应的数据库厂商提供的（第三方公司提供的JAR包），连接或直接操作数据库
  4. 具体通过以下的类/接口实现：
    • DriverManager：管理JDBC驱动
    • Connection：与数据库建立连接（连接字符串加用户名加密码）
    • Statement（子接口PreparedStatement）：实现增删改查
    • CallableStatement：调用数据库中的存储过程/存储函数
    • Result：返回的结果集

JDBC访问数据库的步骤

  1. 导入驱动包，加载具体的驱动类
  2. 与数据库建立连接
  3. 发送sql语句，执行
  4. 处理结果集（对于增删改来说，返回的是多少行被修改（int），对于查来说，无疑是返回查询结果（ResultSet））

各数据库对JDBC提供的接口

下面表中的端口号都是默认端口号：

数据库驱动的jar包名驱动类连接字符串
Oracleojdbc-x.jaroracle.jdbc.driver.OracleDriverjdbc:oracle:thin:@主机名:1521:数据库名称
MySQL8.0以前版本mysql-connector-java-x.jarcom.mysql.jdbc.Driverjdbc:mysql://主机名:3306/数据库名称
MySQL8.0以后版本mysql-connector-java-x.jarcom.mysql.cj.jdbc.Driverjdbc:mysql://localhost:3306/数据库名称?serverTimezone=格林威治时间
sqlserversqljdbc.-x.jarcom.microsoft.sqlserver.jdbc.SQLServerDriverjdbc:microsoft:sqlserver:localhost:1433;databasename=数据库名称

小技巧：大多数的jar包可以在百度搜索，在百度搜索mysql-connector-java.jar mvn（在maven库中查找），之后选择图中的第一个https://mvnrepository.com/artifact/mysql/mysql-connector-java，可以直接下载，也可以在自己下载的数据库的安装目录找：
在这里插入图片描述

实例

加载具体的驱动类

try {
	//对应的数据库使用对应的驱动类，如Oracle：
   Class.forName("oracle.jdbc.driver.OracleDriver");
} catch(ClassNotFoundException e) {
   . . .
}

建立连接

//URL为连接字符串：jdbc:oracle:thin:@主机名:1521:数据库名称
String URL = "jdbc:oracle:thin:@主机名:1521:数据库名称";
String USER = "username";
String PASS = "password"
//记得3个参数：连接字符串，用户名，密码
Connection conn = DriverManager.getConnection(URL, USER, PASS);

关闭连接

在JDBC程序的末尾，显式地需要关闭与数据库的所有连接以结束每个数据库会话。但是，如果忘记了，Java的垃圾收集器在清理陈旧对象时将关闭连接。

依靠垃圾回收，尤其是在数据库编程中，是非常糟糕的编程实践，所以我们应该养成始终使用与连接对象关联的close()方法关闭连接的习惯。

为了确保关闭连接，我们可以在代码中提供一个“finally”块。

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

Statement对象

Statement stmt = null;
try {
   stmt = conn.createStatement();
   . . .
} catch (SQLException e) {
   . . .
} finally {
	//和connection一样，我们需要将statement关闭
	try{
		if(stmt!=null)stmt.close();
	} catch (SQLException e) {
		e.printStackTrace();
	} 
}

一旦创建了Statement对象，就可以使用其三个执行方法之一来执行SQL语句。

  • boolean execute(String SQL)：如果可以检索到ResultSet对象，则返回布尔值true。否则，它返回false。当需要使用真正的动态SQL时，请使用此方法执行SQL DDL语句。
  • int executeUpdate(String SQL)：返回受SQL语句执行影响的行数。使用此方法可以执行您希望受影响的行数的SQL语句，例如，INSERT，UPDATE或DELETE语句。
  • ResultSet executeQuery(String SQL)：返回ResultSet对象。当您希望获得结果集时，请使用此方法，就像使用SELECT语句一样。

PreparedStatement对象

PreparedStatement的接口扩展了Statement接口，可以动态提供参数：

PreparedStatement pstm = null;
try {
   String SQL = "Update 数据库表 SET age = ? WHERE id = ?";
   pstm = conn.prepareStatement(SQL);
   . . .
} catch (SQLException e) {
   . . .
} finally {
	//父类statement都要关闭，何况子类
   try{
		if(pstm!=null)pstm.close();
	} catch (SQLException e) {
		e.printStackTrace();
	}	
}

  1. JDBC中的参数都由?占位符表示，称为参数标记。在执行SQL语句之前，必须为每个参数提供值。

  2. setXXX()方法绑定值的参数，其中XXX代表要绑定到输入参数的值的Java数据类型，分别由setInt()、setString()、setDate()组成。如果忘记提供值，则将收到一个SQLException。

  3. 每个参数标记都由其顺序位置引用。第一个标记代表位置1，第二个代表位置2，依此类推，如setInt(1,20);或setString(2,“20”);。此方法不同于Java数组从0开始的索引。

  4. 与数据库交互的所有Statement对象的方法（a）execute()，（b）executeQuery()和（c）executeUpdate()，PreparedStatement对象也可以使用。但是，方法被修改为使用可以输入参数的SQL语句。

Statement和PreparedStatement

Statement和PreparedStatement有以下一些差别：

  1. PreparedStatement执行的SQL语句，处理的数据可以用占位符?替换，而Statement不可以；
  2. PreparedStatement调用setInt()、setString()、setDate()方法替换占位符；
  3. PreparedStatement对执行的SQL语句进行预编译处理，之后再交给数据库执行SQL操作，而Statement没有这一过程。

推荐使用PreparedStatement，原因如下：

  • 占位符的使用使得编码更加简便，同时避免了字符串的拼接：
    对于日常功能的开发，我们会出现如下的情况：
String name="zs";
int age=23;
Connection conn=……
//Statement stmt
Statement stmt=conn.createStatement();
String SQL="insert into emp(name,age) values('"+name+"',"+age+")";
stmt.executeUpdat(SQL);
//PreparedStatement pstm
String SQL="insert into emp(name,age) values(?,?)";
PreparedStatement pstm=conn.prepareStatement(SQL);//预编译SQL
pstm.setString(1, name);
pstm.setInt(2, age);
  • 提高性能（由上面的例子可知，因为有预编译操作，预编译只需要执行一次）
    如需要重复增加1000条数据：
Connection conn=……
//Statement stmt
Statement stmt=conn.createStatement();
String SQL = "insert into student(name,age) values ('"+name+"',"+age+")";
for(1000)
	stmt.executeUpdate(SQL);
//PreparedStatement pstm
String SQL="insert into student(name,age) values (?,?)";
PreparedStatement pstm=conn.prepareStatement(SQL);//预编译
pstm.setString(1,name);
pstm.setInt(2,age);
for(1000)
	pstm.executeUpdate();
  • 安全（可以有效防止SQL注入）
    SQL注入：将客户输入的内容和开发人员的SQL语句混为一体
    stmt：存在被SQL注入的风险
    （例如输入用户名：任意值’ or 1=1 --密码：任意值）
    分析：
    select count() from login where name=‘任意值’ or 1=1 –’ and pwd =‘任意值’;拼接之后，-- 后面的语句被注释了，这个SQL语句就变成select count() from login where name=’*任意值’ or 1=1;如果这是一个登录的SQL语句，返回的结果就是1，用户就登录成功了。
    但是如果使用PreparedStatement，则可以有效的防止SQL注入，因为占位符并不是把内容直接拼接的。

CallableStatement对象

正如Connection对象创建Statement和PreparedStatement对象一样，它也创建CallableStatement对象（Connection.prepareCall(SQL);），该对象将用于执行对数据库存储过程的调用。
参数格式：

  • 存储过程（无返回值return，用out参数代替）：{call 存储过程名（参数列表）}
  • 存储函数（有返回值return ）：{? = call 存储函数名（参数列表）}
    存在三种类型的参数：IN，OUT和INOUT。PreparedStatement对象仅使用IN参数。CallableStatement对象可以使用所有这三个对象。
参数作用
IN创建SQL语句时其值未知的参数。您可以使用setXXX()方法将值绑定到IN参数
OUT一个参数，其值由返回的SQL语句提供。您可以使用getXXX()方法从OUT参数中检索值
INOUT提供输入和输出值的参数。您可以使用setXXX()方法绑定变量，并使用getXXX()方法检索值

我们看一下例子，使用的是Oracle数据库：

--存储过程的Sql语句
create or replace procedure addTwoNum(num1 in number,num2 in number,result out number) --1+2=3
as
begin
result:=num1+num2;
end;
/

--存储函数的Sql语句
create or replace function addTwoNumfunction(num1 in number,num2 in number)  --1+2
return number
as
result number;
begin
result:=num1+num2;
return result;
end;
/

//java代码
import java.sql.*;
public class CallableStatementTest{
	// JDBC 驱动和数据库连接字符串
	static final String JDBC_DRIVER = "oracle.jdbc.OracleDriver";
	static final String DB_URL = "jdbc:oracle:thin:@主机名:1521:EMP";

	// 数据库用户名密码
	static final String USER = "username";
	static final String PASS = "password";

	// Connection、CallableStatement
	static Connection conn = null;
	static CallableStatement cstm = null;
	//存储过程
	public static void storeProcedure(){
		//导入驱动，加载具体的驱动类
		Class.forName(JDBC_DRIVER);
		//与数据库建立连接
		conn=DriverManager.getConnection(DB_URL,USER ,PASS );
		//发送SQL语句
		cstm=conn.prepareCall("{call addTwoNum(?,?,?)}");
		cstm.setInt(1,20);
		cstm.setInt(2,40);
		cstm.registerOutParameter(3,Types.INTEGER);
		cstm.execute();//num1+num2,execute()之前处理输入参数，之后处理输出参数
		//设置输出参数的类型
		int result=cstm.getInt(3);
		System.out.println(result);
	}
	//存储函数
	public static storedFunction(){
		//导入驱动，加载具体的驱动类
		Class.forName(JDBC_DRIVER);
		//与数据库建立连接
		conn=DriverManager.getConnection(DB_URL,USER ,PASS );
		//发送SQL语句
		cstm=conn.prepareCall("{?= call addTwoNumfunction(?,?)}");
		cstm.setInt(2,20);
		cstm.setInt(3,40);
		cstm.registerOutParameter(1,Types.INTEGER);
		cstm.execute();//num1+num2,execute()之前处理输入参数，之后处理输出参数
		//设置输出参数的类型
		int result=cstm.getInt(1);
		System.out.println(result);
	}
}

注意：如果是通过sqlplus访问数据库，只需要开启：OracleServiceSID，通过其他程序访问数据（sqldevelop、navicate、JDBC），需要开启：OracleServiceSID、XxxListener。
JDBC调用存储过程、存储函数的步骤：

  1. 产生调用存储过程的对象：CallableStatement cstm=Connection.prepareCall(SQL);
  2. 通过setXxx()处理输入参数值：cstm.setInt(1,30);
  3. 通过registerOutParameter()处理输出的参数类型：cstm.registerOutParameter(1,Types.INTEGER);
  4. cstm.execute()执行
  5. 接收输出值（返回值）getXxx()：int result=cstm.getInt(1);
  6. 在调用时，注意参数的区别，存储过程的SQL："{call addTwoNum(?,?,?)}"，存储函数的SQL："{?= call addTwoNumfunction(?,?)}"，所以，前者的返回值为cstm.registerOutParameter(3,Types.INTEGER);int result=cstm.getInt(3);后者的返回值为cstm.registerOutParameter(1,Types.INTEGER);int result=cstm.getInt(1);具体的开发情况具体分析。

处理结果集

ResultSet rs = null;
try {
   //如果返回的结果集只有一条数据
   if(rs.next()){
   		rs.getXxx(int/String);
   		rs.getXxx(int/String);
  		. . .
  	}
  	//返回多条结果集
  	while(rs.next()){
  		rs.getXxx(int/String);
  		rs.getXxx(int/String);
  		. . .
  	}
} catch (SQLException e) {
   . . .
} finally {//先打开后关闭
	try {
		if(rs != null)rs.close();
	} catch (SQLException e) {
		e.printStackTrace();
	}
}

总结

  1. DriverManager创建Connection连接对象；
  2. Connection创建操作数据库的对象：
    a. Connection创建Statement对象：createStatement();
    b. Connection创建PreparedStatement对象：prepareStatement();
    c.Connection创建CallableStatement对象：prepareCall();
  3. Statement操作数据库：
    a. 增删改executeUpdate()，返回值为int，表示有多少行受到影响；
    b. 查询 executeQuery()，返回值为ResultSet结果集，将查询获取的数据以结果集返回；
  4. ResultSet结果集：
    a. 返回的结果集默认位置指向结果集的前一行
    b. next()方法作用：把结果集的游标下移，同时判断下移之后的元素是否有数据，如果有数据，返回true，没有数据，返回false
    c. 获取结果集的数据：getInt(int/String)返回int值，getString(int/String)返回字符串，getDate(int/String)返回日期，(int/String)内可以传int参数或者字符串，如图：
    在这里插入图片描述

整合

//Connection类、Statement类、PreparedStatement类、ResultSet类都是在java.sql.*下
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class Test1 {
	// JDBC 驱动和数据库连接字符串
	static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
	static final String DB_URL = "jdbc:mysql://localhost:3306/EMP";

	// 数据库用户名密码
	static final String USER = "username";
	static final String PASS = "password";

	// Connection、Statement、PreparedStatement
	static Connection conn = null;
	static Statement stmt = null;
	static PreparedStatement pstm = null;
	static ResultSet rs = null;

	// 查
	public static void query() {
		try {
			// 注册驱动
			Class.forName(JDBC_DRIVER);
			// 建立连接
			conn = DriverManager.getConnection(DB_URL, USER, PASS);
			/*Statement
			// 执行SQL语句
			String SQL = 
			"select id,name from emp where name like '%zs%'";
			stmt = conn.createStatement();
			ResultSet rs = stmt.executeQuery(SQL);*/
			//PreparedStatement
			String SQL = "select id,name from emp where name like ?";
			pstm=conn.prepareStatement(SQL);//预编译
			pstm.setString(1, "%zs%");
			rs=pstm.executeQuery();
			while (rs.next()) {
				int id = rs.getInt("id");
				String name = rs.getString("name");
				System.out.println("id: " + id + ", name: " + name);
			}
		}
		// jdbc中，除了Class.forName()抛出ClassNotFoundException外，其他的抛SQLException
		catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {//先打开后关闭
			try {
				if(rs != null)//有结果集，结果集也要关闭
					rs.close();
				if (stmt != null)
					stmt.close();
				if (conn != null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

	// 增删改
	public static void insert() {
		try {
			//驱动注册
			Class.forName(JDBC_DRIVER);
			//建立连接
			conn=DriverManager.getConnection(DB_URL);
			/*Statement	
			//执行SQL语句
			String SQL="insert into emp values(1,'zs')";//增
//			String SQL="delete from emp where id=1";//删
//			String SQL="update emp set name='ls' where id=1";//改
			stmt=conn.createStatement();
			int result=stmt.executeUpdate(SQL);
			*/
			//PreparedStatement
			//执行SQL语句
			String SQL="insert into emp values(?,?)";//增
//			String SQL="delete from emp where id=?";//删
//			String SQL="update emp set name=? where id=?";//改
			pstm=conn.prepareStatement(SQL);//预编译
			pstm.setInt(1, 1);
			pstm.setString(2, "zs");
			int result=pstm.executeUpdate();
			if(result>0) System.out.println("操作成功！！！");
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {//先打开后关闭
			try {
				if (pstm != null)
					pstm.close();
				if (conn != null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

扩展例子

处理稍大型的数据

JDBC存储及下载大文本数据（CLOB）

不同数据库中对应CLOB（大文本数据）的类型如下：

  • MySQL中：CLOB对应TEXT
  • DB2/Oracle中：CLOB对应CLOB
存储小说到数据库
  1. 先通过PreparedStatement的?占位符代替小说内容
  2. 再通过PreparedStatement的setCharaterStream(int,Reader,(int/long)File.length())方法将代替小说的占位符替换为数据流，其中第三个参数是小说的文件大小，用int或long数，最好使用long。

以Oracle数据库为例，MySql数据库同理（把CLOB换成TEXT）：

create table novel (id number primary key,novle clob);

public static void clob(){
	Connection conn = null;
	PreparedStatement pstm = null;
	try{
		//导入驱动，加载具体的驱动类
		Class.forName("oracle.jdbc.OracleDriver");//加载具体驱动类
		//与数据库建立连接
		conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:EMP","username","password");
		//发送SQL语句
		String SQL = "insert into novel values(?,?)";
		pstm = conn.prepareStatement(SQL);
		pstm.setInt(1,1);
		File file = new File("D:\\novel.txt");//小说文件对象
		InputStream in = new FileInputStream(file);
		Reader reader = new InputStreamReader(in,"UTF-8");//设置编码，最好与数据库编码一致
		//设置CLOB类型：setCharacterStream
		pstm.setCharacterStream(2,reader,file.length());//JDK1.2之后有第三个参数，JDK1.6之后就可以用long数据类型了，1.6之前只能用int
		int count = pstm.executeUpdate();
		//处理结果
		if(count > 0)System.out.println("保存成功！！！")
		reader.close();
		in.close();
	}catch (ClassNotFoundException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (SQLException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} finally {//先打开后关闭
		try {
			if (pstm != null)
				pstm.close();
			if (conn != null)
				conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
从数据库取小说
  1. 通过Reader reader=rs.getCharacterStream(“novel”);将clob类型的数据保存到Reader对象中
  2. 将Reader通过Writer输出到指定的位置
public static void clob(){
	Connection conn = null;
	PreparedStatement pstm = null;
	ResultSet rs = null;
	try{
		//导入驱动，加载具体的驱动类
		Class.forName("oracle.jdbc.OracleDriver");//加载具体驱动类
		//与数据库建立连接
		conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:EMP","username","password");
		//发送SQL语句
		String SQL = "select novel from novel where id=?";
		pstm = conn.prepareStatement(SQL);
		pstm.setInt(1,1);
		rs = pstm.executeQuery();
		//处理结果
		if(rs.next()){
			Reader reader = rs.getCharacterStream("novel");
			Writer writer = new FileWriter("src/novel.txt");//设置文件存放位置
			char[] chs = new char[100];
			int len = -1;
			while((len = reader.read(chs))!=-1){
				writer.write(chs,0,len);
			}
			writer.close();
			reader.close();
		}
	}catch (ClassNotFoundException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (SQLException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} finally {//先打开后关闭
		try {
			if (rs != null)
				rs.close();
			if (pstm != null)
				pstm.close();
			if (conn != null)
				conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

JDBC存储及下载二进制文件（BLOB）

数据库也可以存储二进制文件如图片、音乐、文档等等的文件。

存储图片到数据库

操作与上文的大文本数据差不多，区别在于设置BLOB类型的方法为setBinaryStream()，参数大致相同不加赘述，案例如下：
以Oracle数据库为例，MySql数据库同理：

create table picture(id number primary key,picture blob);

public static void blob(){
	Connection conn = null;
	PreparedStatement pstm = null;
	try{
		//导入驱动，加载具体的驱动类
		Class.forName("oracle.jdbc.OracleDriver");//加载具体驱动类
		//与数据库建立连接
		conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:EMP","username","password");
		//发送SQL语句
		String SQL = "insert into picture values(?,?)";
		pstm = conn.prepareStatement(SQL);
		pstm.setInt(1,1);
		File file = new File("D:\\picture.jpg");//图片文件对象
		InputStream in = new FileInputStream(file);
		//设置BLOB类型：setBinaryStream
		pstm.setBinaryStream(2,in,file.length());//JDK1.2之后有第三个参数，JDK1.6之后就可以用long数据类型了，1.6之前只能用int
		int count = pstm.executeUpdate();
		//处理结果
		if(count > 0)System.out.println("保存成功！！！")
		in.close();
	}catch (ClassNotFoundException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (SQLException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} finally {//先打开后关闭
		try {
			if (pstm != null)
				pstm.close();
			if (conn != null)
				conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
从数据库取图片

操作也和上文大体类似：

public static void blob(){
	Connection conn = null;
	PreparedStatement pstm = null;
	ResultSet rs = null;
	try{
		//导入驱动，加载具体的驱动类
		Class.forName("oracle.jdbc.OracleDriver");//加载具体驱动类
		//与数据库建立连接
		conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:EMP","username","password");
		//发送SQL语句
		String SQL = "select picture from picture where id=?";
		pstm = conn.prepareStatement(SQL);
		pstm.setInt(1,1);
		rs = pstm.executeQuery();
		//处理结果
		if(rs.next()){
			InputStream in = rs.getBinaryStream("picture");
			OutputStream out = new FileOutputStream("src/picture.jpg");//设置文件存放位置
			byte[] byt = new byte[100];
			int len = -1;
			while((len = in.read(byt))!=-1){
				out.write(byt,0,len);
			}
			out.close();
			in.close();
		}
	}catch (ClassNotFoundException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (SQLException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} finally {//先打开后关闭
		try {
			if (rs != null)
				rs.close();
			if (pstm != null)
				pstm.close();
			if (conn != null)
				conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

JDBC存储文件路径

这个在开发中使用比较多也比较方便，主要是文件太大了存储数据库也不方便，容易卡顿，所以保存文件名在数据库中，需要时再下载无疑是一种好办法：
通过JDBC存储文件路径，然后根据IO操作处理，例如：JDBC将D:\novel.txt文件以字符串的形式"D:\novel.txt"存储在数据库中，获取时只要获取该文件路径然后通过IO的方式处理即可：

向数据库中存储地址
public static void insert(){
	Connection conn = null;
	PreparedStatement pstm = null;
	try{
		//导入驱动，加载具体的驱动类
		Class.forName("oracle.jdbc.OracleDriver");//加载具体驱动类
		//与数据库建立连接
		conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:EMP","username","password");
		//发送SQL语句
		String SQL = "insert into url values(?,?)";
		pstm = conn.prepareStatement(SQL);
		pstm.setInt(1,1);
		pstm.setString(2,"D:\\novel.txt");
		int count = pstm.executeUpdate();
		//处理结果
		if(count > 0)System.out.println("保存成功！！！")
	}catch (ClassNotFoundException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (SQLException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} finally {//先打开后关闭
		try {
			if (pstm != null)
				pstm.close();
			if (conn != null)
				conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
从数据库中取文件地址

我们把文件保存到D:\download\novel.txt吧：

public static void download(){
	Connection conn = null;
	PreparedStatement pstm = null;
	ResultSet rs = null;
	try{
		//导入驱动，加载具体的驱动类
		Class.forName("oracle.jdbc.OracleDriver");//加载具体驱动类
		//与数据库建立连接
		conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:EMP","username","password");
		//发送SQL语句
		String SQL = "select url from url where id=?";
		pstm = conn.prepareStatement(SQL);
		pstm.setInt(1,1);
		rs = pstm.executeQuery();
		//处理结果
		if(rs.next()){
			String url = rs.getString(url);
			File file = new File(url);//小说文件对象
			InputStream in = new FileInputStream(file);
			OutputStream out = new FileOutputStream("D:\\download\\novel.txt");//设置文件存放位置
			byte[] byt = new byte[100];
			int len = -1;
			while((len = in.read(byt))!=-1){
				out.write(byt,0,len);
			}
			out.close();
			in.close();
		}
	}catch (ClassNotFoundException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (SQLException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	} finally {//先打开后关闭
		try {
			if (rs != null)
				rs.close();
			if (pstm != null)
				pstm.close();
			if (conn != null)
				conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}

JDBC执行SQL语句

JDBC创建数据库

import java.sql.*;

public class createDatabase {
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql//localhost:3306/";
   static final String USER = "username";
   static final String PASS = "password";
   
   public static void main(String[] args) {
	   Connection conn = null;
	   Statement stmt = null;
	   try{
	      //注册驱动
	      Class.forName(JDBC_DRIVER);
	
	      //建立连接
	      conn = DriverManager.getConnection(DB_URL, USER, PASS);
	
	      //执行SQL语句
	      stmt = conn.createStatement();
	      
	      String SQL = "CREATE DATABASE STUDENTS";
	      stmt.executeUpdate(SQL);
	      System.out.println("数据库创建成功");
	   }catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {//先打开后关闭
			try {
				if (stmt != null)
					stmt.close();
				if (conn != null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

JDBC删除数据库

import java.sql.*;

public class dropDatabase{
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql//localhost:3306/";
   static final String USER = "username";
   static final String PASS = "password";
   
   public static void main(String[] args) {
	   Connection conn = null;
	   Statement stmt = null;
	   try{
	      //注册驱动
	      Class.forName(JDBC_DRIVER);
	
	      //建立连接
	      conn = DriverManager.getConnection(DB_URL, USER, PASS);
	
	      //执行SQL语句
	      stmt = conn.createStatement();
	      
	      String SQL = "DROP DATABASE STUDENTS";
	      stmt.executeUpdate(SQL);
	      System.out.println("数据库删除成功");
	   }catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {//先打开后关闭
			try {
				if (stmt != null)
					stmt.close();
				if (conn != null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

创建数据库表

import java.sql.*;

public class CreateTable {
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql//localhost:3306/STUDENTS";
   static final String USER = "username";
   static final String PASS = "password";
   
   public static void main(String[] args) {
	   Connection conn = null;
	   Statement stmt = null;
	   try{
	      //注册驱动
	      Class.forName(JDBC_DRIVER);
	
	      //建立连接
	      conn = DriverManager.getConnection(DB_URL, USER, PASS);
	
	      //执行SQL语句
	      stmt = conn.createStatement();
	      
	      String SQL = "CREATE TABLE REGISTRATION " +
	                   "(id INTEGER not NULL, " +
	                   " name VARCHAR(255), " +
	                   " age INTEGER, " + 
	                   " PRIMARY KEY ( id ))"; 
	
	      stmt.executeUpdate(SQL);
	      System.out.println("成功创建数据库表");
	   }catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {//先打开后关闭
			try {
				if (stmt != null)
					stmt.close();
				if (conn != null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

删除数据库表

import java.sql.*;

public class JDBCExample {
   static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
   static final String DB_URL = "jdbc:mysql//localhost:3306/STUDENTS";
   static final String USER = "username";
   static final String PASS = "password";
   
   public static void main(String[] args) {
	   Connection conn = null;
	   Statement stmt = null;
	   try{
	      //注册驱动
	      Class.forName(JDBC_DRIVER);
	
	      //建立连接
	      conn = DriverManager.getConnection(DB_URL, USER, PASS);
	
	      //执行SQL语句
	      stmt = conn.createStatement();
      
	      String SQL = "DROP TABLE REGISTRATION ";
	 
	      stmt.executeUpdate(SQL);
	      System.out.println("成功删除数据库表");
	    }catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {//先打开后关闭
			try {
				if (stmt != null)
					stmt.close();
				if (conn != null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}
JAVA之数据库JDBC学习心得
jackson0215的专栏
07-06 3042
JAVA之数据库JDBC学习心得
Java个人总结——JDBC基本语法
冷漠的小猿
09-08 2137
JDBC的使用 一、JDBC初始 构建JDBC应用程序涉及以下六个步骤： 导入JDBC驱动包：需要下载包含数据库编程所需的JDBC的jar包。 注册JDBC驱动程序：要求你初始化驱动程序，以便您可以打开与数据库的通信通道。 创建连接：需要使用DriverManager.getConnection（）方法创建一个Connection对象，该对象表示与数据库的物理连接。 执行查询：需要使用类型...
java JDBC自我总结
weixin_30674525的博客
05-15 144
preparedstatement和statement的区别 当不需要预编译时（不需要占位符）可以选用statement,存在不安全 当有占位符（？）时，需要选用preparedstatement select 查询语句，选用executeQuery（）方法 执行后返回代表查询结果的ResultSet对象 ResultSetrs=pst.executeQuery("select*...
jdbc 心得总结
wangweijun125455的专栏
03-10 1128
<br />jdbc 心得总结<br />首先  jdbc  是一个连接数据库的协议标准，每一个数据库厂商都有自己的实现。 <br />步骤 如下<br />1， 加载数据库驱动<br />2， 创建连接 （可以使用连接池，就是把连接对象放进 一个集合，用于之后在放回集合中，连接信息可以放在一个属性文件中）<br />3， 创建语句对象（Preparedstatement 用的好 ，防止sql注入）<br />4，执行sql语句 (如果执行语句比较多的话，使用batch,还可以获取执行后的id)，获取结果集
JDBC总结大全
weixin_53866772的博客
07-11 596
一、JDBC概述 概念：Java DataBase Connectivity Java 数据库连接， Java语言操作数据库            JDBC 规范定义接口，具体的实现由各大数据库厂商来实现。            JDBC可让Java通过程序操作关系型数据库，JDBC基于驱
2019年java培训个人总结例文参照.doc
11-23
在Java培训中，通常还会涉及JDBC（Java Database Connectivity）以学习数据库操作，以及Servlet和JSP用于Web开发。JDBC允许Java程序连接和操作各种类型的数据库，而Servlet和JSP是构建动态网站的常用技术，它们可以...
"个人Java总结：JDBC、Servlet应用与浏览器编码格式探索
个人Java总结： 在我使用Java进行开发过程中，我对JDBC和Servlet进行了深入的研究和使用，以下是我的总结。 JDBC（Java Database Connectivity）是Java与数据库进行交互的重要工具。通过JDBC，我可以连接数据库，...
基于jsp+jdbc+servlet的个人CMS系统，课程大作业.zip
10-11
总结来说，这个项目是一个使用JSP、JDBC和Servlet技术构建的个人内容管理系统，涵盖了Web开发的基本要素，包括前端展示、后端处理和数据库交互。对于学习Java Web开发的学生而言，这是一个很好的实践平台，可以深入...
构建个人通讯录管理系统：JSP+Struts+JDBC技术应用
在当今的互联网时代，个人通讯录管理系统已经成为了人们生活中不可或缺的一部分。这种系统可以帮助用户...而对于学习者来说，通过这样的项目实践，可以加深对JSP、Struts和JDBC技术的理解，并提高Web应用开发的技能。
JDBC直连（个人总结综合教程，适合新入门的朋友阅读）
01-13
**JDBC直连详解** Java Database ...通过学习和实践，你可以熟练地利用JDBC进行数据库操作。记得在实际项目中，结合连接池和事务管理等技术，提升应用的性能和稳定性。祝你在Java数据库编程的道路上越走越远！
1.JDBC
自我学习总结
04-17 318
文章目录一.概述二. 获取数据库连接三.JDBC常用API四.DDL五.DML六.DQL&ResultSet七.Java和MySQL的类型八.DAO九.代码实现十.简单的学生管理系统 一.概述 JDBC隶属于JavaSE的范畴,伴随着JavaSE的版本升级. JDBC(Java DataBase Connectivity): 是一种用于执行SQL语句的Java API，可以为多种关系数...
项目总结（六） jdbc
chenxiyuan程序员
12-02 260
jdbc.dirver=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/yt_logistics?useUnicode=true&amp;characterEncoding=utf8&amp;autoReconnect=true jdbc.username=root jdbc.password=123456
超详细的JDBC总结
weixin_44197039的博客
03-12 651
JDBC概述 1.JDBC的理解 JDBC简介:JDBC是java数据库连接技术的简称,提供各种常用数据库的能力。全称是 Java Database Connectivity,它是一种可用于执行sql语句的 Java API(Application Programming Interface , 应用程序设计接口)。 JDBC本质：是sun公司定义的一套操作所有关系型数据库的规则，即接口。各个数据...
Java JDBC连接数据库实现增删改查
热门推荐
泡泡的博客
06-29 1万+
Java JDBC实现数据库增删改查前言文件结构在util包下新建DBUtil类在bean包下新建User类在dao包下新建UserDao类新建Test类解释一下bean包、dao包 前言 接着上一篇文章，增删改查的整合版本 文件结构 在util包下新建DBUtil类 将JDBC的基本步骤的1、2、7步放入DBUtil类中，代码中使用了try…catch，也可以直接idea自动生成抛出异常 package com.XuYijie.util; import java.sql.*; public clas
jdbc实现数据库基本操作（增，删，改，查）
qq_75222206的博客
07-10 3398
【代码】jdbc实现数据库基本操作（增，删，改，查）
JDBC执行删除与更新
weixin_52385232的博客
09-09 1164
JDBC执行删除与更新
jdbc基础之删除和修改
最新发布
洛洛呀。的博客
06-21 553
/创建Statement,执行sql。//创建Statement,执行sql。//执行sql，返回影响的行数。//执行sql，返回影响的行数。//关闭连接，释放资源。//关闭连接，释放资源。
JDBC的增删改查
二哈喇子！
07-06 4688
知不知道JDBC增删改查操作中只有查询需要处理结果集
JDBC总结
一份耕耘，一分收获
02-25 2148
韩顺平讲Java JDBC总结
评论
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值