fehly
- 浏览: 250248 次
- 性别:
- 来自: 上海
-
文章分类
最新评论
-
javatozhang：
讲解的的确不错。很实用。
Hibernate数据拦截与事件监听 -
sjx19871109：
更正一个地方：<event type="pos ...
Hibernate search -
xifan：
你好，楼主。
mutable="false 好像是 ...
Hibernate持久化对象生命周期 -
leo_cao：
很好，很实用
Hibernate数据拦截与事件监听 -
fehly：
47816778 写道你这样不会出现number 的精度问题吗 ...
Hibernate Annotations
数据库简介
数据库(DB,Data Base)
数据库管理系统(DBMS,Data Base Management Systenm)
关系型数据库（RDB）
关系型数据库管理系统（RDBMS）
SQL语言（Structured Query Language）
- 使用关系模型的数据库语言，用于和各类数据库的交互，提供通用的数据管理和查询功能。
- 常用SQL指令：SELECT 、INSERT、DELETE、UPDATE、CREATE、DROP
ODBC（Open DataBase Connectivity开放式数据库互连）
- 数据库系统应用程序接口规范。
- 支持应用程序以标准的ODBC函数和sql语句操作各种不同类型的数据库
操作各种不同类型的数据库。
JDBC
JDBC（Java DataBase Connectivity）
JDBC功能:
- 支持基本SQL语句，在Java程序中实现数据库操作功能并简化操作过程
- 提供多样化的数据库连接方法
- 为各种不同的数据库提供统一的操作界面
JDBC API
- java.sql. DriverManager类
- java.sql.Driver接口
- java.sql.Connection接口
- java.sql.Statement接口
- java.sql.ResultSet接口
JDBC工作原理
JDBC驱动程序
数据库驱动程序（DataBase Driver）
JDBC驱动程序分类:
- 第一类：JDBC-OCBC桥
- 第二类：Java到本地API
- 第三类：Java到网络协议
- 第四类：Java到数据库协议
数据库URL
JDBC技术中使用数据库URL来标识目标数据库
数据库URL格式：
jdbc:<子协议名>:<子名称>
- "jdbc"为协议名，确定不变；
- <子协议名>指定目标数据库的种类和具体连接方式；
- <子名称>指定具体的数据库/数据源连接信息（如数据库服务器的IP地址/通信端口号、ODBC数据源名称、连接用户名/密码等）。
- 子名称的格式和内容随子协议的不同而改变。
举例：
jdbc:oracle:thin:@222.212.32.14:1521:dbrbh jdbc:microsoft:sqlserver://127.0.0.1:1433 jdbc:microsoft:sqlserver://127.0.0.1:1433,databasename=pubs jdbc:mysql://127.0.0.1/db_rbh
JDBC编程
JDBC编程基本步骤
1. 加载驱动程序（向系统注册所需的JDBC驱动程序）；
2. 建立到指定数据库的连接；
3. 提交数据库查询；
4. 取得查询结果
import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class JDBCExample{
public static void main(String args[]){
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@127.0.0.1:1521:dbrbh";
Connection conn = DriverManager.getConnection(url,"scott","tiger");
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("select * from dept");
while(rs.next()){
System.out.print("DeptNo: " + rs.getInt(1));
System.out.print("\tDeptName: " + rs.getString(2));
System.out.println("\tLOC: " + rs.getString(3));
}
rs.close();
stmt.close();
conn.close();
}catch(ClassNotFoundException e){
System.out.println("找不到指定的驱动程序类!");
}catch(SQLException e){
e.printStackTrace();
}
}
}
ResultSet常用get...()方法 SQL-Java类型对应关系
执行DML语句
create table student(
sid char(10),
name char(20),
age number(3));
insert into student values('J001','张三',18);
insert into student values('J002','李四',20);
insert into student values('J003','王五',19);
import java.sql.*;
public class TestDML{
public static void main(String args[]){
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@127.0.0.1:1521:dbrbh";
Connection conn = DriverManager.getConnection(url,"scott","tiger");
Statement stmt = conn.createStatement();
stmt.executeUpdate("insert into student values('J001','张三',18)");
stmt.executeUpdate("insert into student values('J002','李四',20)");
stmt.executeUpdate("insert into student values('J003','王五',19)");
ResultSet rs = stmt.executeQuery("select * from student");
while(rs.next()){
System.out.print("学号: " + rs.getString(1));
System.out.print("\t姓名: " + rs.getString(2));
System.out.println("\t年龄: " + rs.getInt(3));
}
rs.close();
stmt.executeUpdate("update student set age=age+10");
stmt.executeUpdate("delete from student where sid='J002'");
System.out.println("--------------更新/删除数据后---------------");
rs = stmt.executeQuery("select * from student");
while(rs.next()){
System.out.print("学号: " + rs.getString("sid"));
System.out.print("\t姓名: " + rs.getString("name"));
System.out.println("\t年龄: " + rs.getInt("age"));
}
rs.close();
stmt.close();
conn.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
执行DDL语句
import java.sql.*;
public class TestDDL{
public static void main(String args[]){
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try{
System.setProperty("jdbc.drivers","oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@127.0.0.1:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
stmt = conn.createStatement();
stmt.execute("create table mytable(id number, name char(10), phone char(10))");
stmt.executeUpdate("insert into mytable values(55,'Tom','67666939')");
rs = stmt.executeQuery("select * from mytable");
while(rs.next()){
System.out.println(rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString(3));
}
stmt.execute("drop table mytable");
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(rs != null){
rs.close();
}
}catch(Exception e){
e.printStackTrace();
}
try{
if(stmt != null){
stmt.close();
}
}catch(Exception e){
e.printStackTrace();
}
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
获取数据库元数据
import java.sql.*;
public class TestMetaData{
public static void main(String args[]){
Connection conn = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
ResultSet rs = null;
DatabaseMetaData dmd = conn.getMetaData();
if (dmd == null) {
System.out.println ("No Meta available");
} else {
System.out.println ("数据库名称:" + dmd.getDatabaseProductName());
System.out.println ("数据库版本:" + dmd.getDatabaseProductVersion());
System.out.println ("数据库驱动程序：" + dmd.getDriverName());
System.out.println ("驱动程序版本号：" + dmd.getDriverVersion());
System.out.println ("并发访问的用户个数" + dmd.getMaxConnections());
System.out.println ("数据类型列表：" );
rs = dmd.getTypeInfo();
while(rs.next()){
System.out.println("\t" + rs.getString(1));
}
rs.close();
}
Statement stmt = conn.createStatement();
String s = "select * from dept";
rs = stmt.executeQuery(s);
System.out.println("数据表dept结构信息：");
ResultSetMetaData rsm = rs.getMetaData();
int columnCount = rsm.getColumnCount();
System.out.println("列序号\t列名\t数据类型");
for(int i=1;i<=columnCount;i++){
System.out.println(" " + i + " \t" +
rsm.getColumnName(i) + "\t" +
rsm.getColumnTypeName(i));
}
rs.close();
stmt.close();
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(conn != null && !conn.isClosed()){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
访问SQL Server数据库
准备SQL Server数据库JDBC驱动程序
1. 从微软网站下载JDBC驱动程序安装文件
2. 本地安装该驱动程序包
3. 重新设置CLASSPATH环境变量
import java.sql.*;
public class TestSQLServer{
public static void main(String[] args) {
try{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
Connection con = DriverManager.getConnection
("jdbc:microsoft:sqlserver://127.0.0.1:1433","sc","admin");
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery("select * from mytable1");
while(rs.next()){
System.out.print("sid：" + rs.getInt(1));
System.out.print("\tname：" + rs.getString(2).trim());
System.out.print("\tsex：" + rs.getString(3).trim());
System.out.println();
}
rs.close();
stmt.close();
con.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
JDBC-ODBC编程
工作原理：
JDBC驱动程序管理器并不直接操纵数据库驱动程序，而是调用JDBC-ODBC桥驱动程序操纵,ODBC驱动程序，进而连接各种类型的数据库。
编程步骤：
创建ODBC数据源
在程序中连接并操作ODBC数据源
访问Excel文件
import java.sql.*;
public class JDBC_ODBC{
public static void main(String args[]){
String drv = "sun.jdbc.odbc.JdbcOdbcDriver";
try{
Class.forName(drv);
Connection con = DriverManager.getConnection("jdbc:odbc:ExcelODBC1", "", "");
DatabaseMetaData dmd = con.getMetaData();
if (dmd == null) {
System.out.println ("No DBMeta available");
} else {
System.out.println ("DB Name:\t" + dmd.getDatabaseProductName());
System.out.println ("DB Version:\t" + dmd.getDatabaseProductVersion());
System.out.println ("DB Driver Name:\t" + dmd.getDriverName());
System.out.println ("Driver Version:\t" + dmd.getDriverVersion());
}
Statement stmt=con.createStatement();
ResultSet rs=stmt.executeQuery("select * from [Sheet1$]");
System.out.println("记录内容：");
System.out.println("\t姓 名\t年龄\t月 薪\t职 务" );
while(rs.next()){
System.out.print("\t" + rs.getString(1));
System.out.print("\t" + rs.getInt(2));
System.out.print("\t" + rs.getString(3));
System.out.println();
}
rs.close();
stmt.close();
con.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
访问Access数据库
import java.sql.*;
public class TestAccess{
public static void main(String[] args) {
try{
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
Connection con = DriverManager.getConnection("jdbc:odbc:test", "", "");
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery("select * from table1");
while(rs.next()){
System.out.print("编号:" + rs.getString(1));
System.out.print("\t姓名:" + rs.getString(2));
System.out.print("\t性别:" + rs.getString(3));
System.out.println();
}
rs.close();
stmt.close();
con.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
访问SQL Server数据库
import java.sql.*;
public class TestSQLServer{
public static void main(String[] args) {
try{
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
Connection con = DriverManager.getConnection("jdbc:odbc:mydb1", "", "");
//Connection con = DriverManager.getConnection("jdbc:odbc:mydb1;database=pubs", "", "");
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery("select * from mytable1");
while(rs.next()){
System.out.print("编号：" + rs.getInt(1));
System.out.print("\t姓名：" + rs.getString(2).trim());
System.out.print("\t性别：" + rs.getString(3).trim());
System.out.println();
}
rs.close();
stmt.close();
con.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
使用属性文件配置环境
将数据库连接信息（URL、用户名/密码等）保存到专门的属性文件中，而不在程序中直接给出
#Oracle db info db_url = jdbc:oracle:thin:@127.0.0.1:1521:dbrbh username = scott password = tiger
import java.io.*;
import java.util.*;
import java.sql.*;
public class JDBCExample{
public static Connection getConnection()throws SQLException,IOException{
Properties ps = new Properties();
FileInputStream fis = new FileInputStream("mydb.properties");
ps.load(fis);
fis.close();
String url = ps.getProperty("db_url");
String username = ps.getProperty("username");
String psw = ps.getProperty("password");
Connection conn = DriverManager.getConnection(url,username,psw);
return conn;
}
public static void main(String args[]){
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection conn = JDBCExample.getConnection();
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("select * from dept");
while(rs.next()){
System.out.print("DeptNo: " + rs.getInt(1));
System.out.print("\tDeptName: " + rs.getString(2));
System.out.println("\tLOC: " + rs.getString(3));
}
rs.close();
stmt.close();
conn.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
OCI方式访问Oracle数据库
OCI方式连接时Oracle客户端配置
使用Net Configuration Assistant
使用Net Manager图形化工具
直接修改数据库配置文件"tnsnames.ora"
import java.sql.*;
public class TestOCI{
public static void main(String args[]){
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
//Connection conn = DriverManager.getConnection("jdbc:oracle:oci:@mdb1","scott","tiger");
Connection conn = DriverManager.getConnection("jdbc:oracle:oci:@(description=(address=(host=127.0.0.1)(protocol=tcp)(port=1521))(connect_data=(sid=ora9)))","scott", "tiger");
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("select * from dept");
while(rs.next()){
System.out.print("DeptNo: " + rs.getInt(1));
System.out.print("\tDeptName: " + rs.getString(2));
System.out.println("\tLOC: " + rs.getString(3));
}
rs.close();
stmt.close();
conn.close();
}catch(Exception e){
e.printStackTrace();
}
}
}
可滚动/可更新结果集
结果集类型
不可滚动（FORWARD_ONLY）
滚动不敏感（SCROLL_INSENSITIVE）
滚动敏感（SCROLL_SENSITIVE）
结果集的并发模式
只读的（READ_ONLY）
可更新的（UPDATABLE）
Connection 接口中提供的重载方法createStatement()用于获取可滚动/可更新结果集。
方法格式：
Statement createStatement(int type,int concurrency)
检测结果集类型
结果集类型与并发模式常量
ResultSet.TYPE_FORWARD_ONLY 不可滚到结果集
ResultSet.TYPE_SCROLL_INSENSITIVE 滚到不敏感结果集
ResultSet.TYPE_SCROLL_SENSITIVE 滚到敏感结果集
ResultSet.CONCUR_READ_ONLY 只读结果集
ResultSet.CONCUR_UPDATABLE 可更新结果集
使用JDBC元数据API进行检测
import java.sql.*;
public class TestMetaData{
public static void main(String args[]){
Connection conn = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
ResultSet rs = null;
DatabaseMetaData dmd = conn.getMetaData();
if (dmd == null) {
System.out.println ("No Meta available");
} else {
System.out.println ("数据库名称:" + dmd.getDatabaseProductName());
System.out.println ("数据库版本:" + dmd.getDatabaseProductVersion());
System.out.println ("数据库驱动程序：" + dmd.getDriverName());
System.out.println ("驱动程序版本号：" + dmd.getDriverVersion());
System.out.println ("--------------------------------------------");
System.out.println ("结果集类型及支持情况(true-支持,false-不支持)");
System.out.println ("TYPE_FORWARD_ONLY: " +
dmd.supportsResultSetType(ResultSet.TYPE_FORWARD_ONLY));
System.out.println ("TYPE_SCROLL_INSENSITIVE: " +
dmd.supportsResultSetType(ResultSet.TYPE_SCROLL_INSENSITIVE));
System.out.println ("TYPE_SCROLL_SENSITIVE: " +
dmd.supportsResultSetType(ResultSet.TYPE_SCROLL_SENSITIVE));
System.out.println ("CONCUR_READ_ONLY: " +
dmd.supportsResultSetType(ResultSet.CONCUR_READ_ONLY));
System.out.println ("CONCUR_UPDATABLE: " +
dmd.supportsResultSetType(ResultSet.CONCUR_UPDATABLE));
}
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
使用可滚动结果集
对于可滚动结果集，可以使用ResultSet接口中定义的下述方法进行遍历：
boolean next()
boolean previous()
boolean first()
boolean last()
void beforeFirst()
void afterLast()
boolean relative(int rows)
boolean absolute(int row)
int getRow()
import java.sql.*;
public class TestScrollResultSet{
public static void main(String args[]){
Connection conn = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
Statement stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
ResultSet rs = stmt.executeQuery("select * from student");
while(rs.next()){
showOneRow(rs);
}
System.out.println("-----------");
rs.last();
showOneRow(rs);
rs.first();
showOneRow(rs);
rs.beforeFirst();
rs.next();
showOneRow(rs);
rs.absolute(2);
showOneRow(rs);
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
public static void showOneRow(ResultSet rs) throws SQLException{
System.out.print("第" + rs.getRow() + "行: ");
System.out.print(rs.getString(1));
System.out.print("\t" + rs.getString(2));
System.out.print("\t" + rs.getString(3));
System.out.println();
}
}
使用可更新结果集
对于可更新结果集，可以使用ResultSet接口中定义的下述方法进行更新操作：
void updateXXX(String columnName, XXX x)
void updateXXX(int columnIndex, XXX x)
void updateRow()
void moveToInsertRow()
void insertRow()
void moveToCurrentRow()
void deleteRow()
void cancelRowUpdates()
import java.sql.*;
public class TestUpdatableResultSet{
public static void main(String args[]){
Connection conn = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
Statement stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet rs = stmt.executeQuery("select tid,name,salary from teacher");
//ResultSet rs = stmt.executeQuery("select teacher.* from teacher");
//更新前结果集中数据
while(rs.next()){
showOneRow(rs);
}
//更新和删除记录
rs.beforeFirst();
while(rs.next()){
String name = rs.getString("name").trim();
if(name.equals("李四")){
double sal = rs.getDouble("salary");
rs.updateDouble("salary", sal + 8888);
rs.updateRow();
}else if(name.equals("张三")){
rs.deleteRow();
}
}
//插入新记录
rs.moveToInsertRow();
rs.updateInt("tid",1005);
rs.updateString("name","张三峰");
rs.updateDouble("salary",2840);
rs.insertRow();
rs.close();
//结果集更新后后数据库中数据
System.out.println("--------------------------------------------");
rs = stmt.executeQuery("select * from teacher");
while(rs.next()){
showOneRow(rs);
}
rs.close();
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
public static void showOneRow(ResultSet rs) throws SQLException{
System.out.print("第" + rs.getRow() + "行: ");
System.out.print(rs.getInt(1));
System.out.print("\t" + rs.getString(2));
System.out.print("\t" + rs.getDouble(3));
System.out.println();
}
}
预处理语句
java.sql.PreparedStatement接口提供了执行预编译SQL语句的功能，它继承了java.sql.Statement接口。
Connection 对象的prepareStatement(String sql)方法可创建并返回PreparedStatement对象。
PreparedStatement接口主要方法：
void setXXX(int parameterIndex, XXX x）
ResultSet executeQuery()
int executeUpdate()
drop table mytable2; create table mytable2(tid number(6), name char(20), salary number(7,2));
import java.sql.*;
public class PrepStmt{
public static void main(String[] args){
Connection con = null;
PreparedStatement pst = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
con = DriverManager.getConnection(url,"scott","tiger");
String sql = "insert into mytable2 values(?,?,?)";
pst = con.prepareStatement(sql);
for(int i = 101;i<200;i++){
pst.setInt(1,i);
pst.setString(2,"Tom" + i);
pst.setDouble(3,(100+i)*10);
pst.executeUpdate();
}
System.out.println("id:\tname:\tsalary:");
pst = con.prepareStatement("select * from mytable2 where id = ?");
pst.setInt(1,157);
ResultSet rs = pst.executeQuery();
if(rs.next()){
System.out.println(rs.getInt(1) + "\t" + rs.getString(2).trim() + "\t" + rs.getDouble(3));
}
int[] ids = {160,171,182};
for(int i:ids){
pst.setInt(1,i);
rs = pst.executeQuery();
if(rs.next()){
System.out.println(rs.getInt(1) + "\t" + rs.getString(2).trim() + "\t" + rs.getDouble(3));
}
}
}catch(Exception e){
System.err.println(e);
}finally{
try{
if(pst != null){
pst.close();
}
}catch(Exception e){
e.printStackTrace();
}
try{
if(con != null){
con.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
调用存储过程
ava.sql.CallableStatement接口提供了调用数据库服务器端存储过程（Procedure）的功能，它继承了 java.sql. PreparedStatement接口。
Connection对象的prepareCall(String sql)方法可创建并返回CallableStatement对象。
CallableStatement接口主要方法：
void setXXX(int parameterIndex, XXX x）
boolean execute()
drop procedure MyProcedure; drop table person; create table person(id number primary key, name char(20), age number); create or replace procedure MyProcedure (pid in number,name in char,age in char) as begin insert into person values(pid,name,age); end; /
import java.sql.*;
public class CallStmt{
public static void main(String[] args){
Connection con = null;
CallableStatement cst = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
con = DriverManager.getConnection(url,"scott","tiger");
cst = con.prepareCall("{call MyProcedure(?,?,?)}");
cst.setInt(1,1001);
cst.setString(2,"Jenny");
cst.setInt(3,48);
cst.execute();
cst.close();
}catch(Exception e){
System.err.println(e);
}finally{
try{
if(con != null){
con.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
事务处理
和数据库中的事务管理模式相对应，JDBC中的Connection对象也可分为自动提交和非自动提交两种模式。
JDBC驱动程序的默认事务管理模式为"自动提交"。
Connection接口提供的事务处理相关方法：
void setAutoCommit(boolean autoCommit)
boolean getAutoCommit()
void commit()
void rollback()
import java.sql.*;
public class TestCommit{
public static void main(String args[]){
Connection conn = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url="jdbc:oracle:thin:@127.0.0.1:1521:dbrbh";
conn=DriverManager.getConnection(url,"scott","tiger");
boolean autoCommit = conn.getAutoCommit();
// 关闭自动提交功能
conn.setAutoCommit(false);
Statement stmt=conn.createStatement();
stmt.executeUpdate("insert into dept values (77,'Market','Beijing')");
stmt.executeUpdate("insert into dept values (88,'R&D','Shanghai')");
ResultSet rs=stmt.executeQuery("select * from dept");
while(rs.next()){
System.out.print("DeptNo: "+rs.getInt(1));
System.out.print("\tDeptName: "+rs.getString(2));
System.out.println("\tLOC: "+rs.getString(3));
}
// 提交事务
conn.commit();
// 恢复原来的提交模式
conn.setAutoCommit(autoCommit);
stmt.close();
}catch(Exception e){
System.out.println("操作失败、任务撤消！");
try{
// 回滚、取消前述操作
conn.rollback();
}catch(Exception e1){
e.printStackTrace();
}
}finally{
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
事务处理之部分回滚
JDBC3.0开始支持在事务中使用保存点（Savepoint），以实现对数据库事务的进一步控制、即支持部分回滚功能。
java.sql.Savepoint接口表示数据库事务中的保存点。
在Connection对象的rollback()方法中可以对当前事务中的保存点进行引用，从而将事务回滚到该保存点。
drop table teacher; create table teacher(tid number(6), name char(20), salary number(7,2));
import java.sql.*;
public class TestSavepoint{
public static void main(String[] args){
Connection conn = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
conn.setAutoCommit(false);
Statement stmt = conn.createStatement();
stmt.executeUpdate("insert into teacher values(11,'Tom',2500)");
stmt.executeUpdate("insert into teacher values(12,'John',3400)");
Savepoint sp1 = conn.setSavepoint("p1");
stmt.executeUpdate("insert into teacher values(13,'Billy',3150)");
Savepoint sp2 = conn.setSavepoint("p2");
stmt.executeUpdate("update teacher set salary = salary+8888 where tid = 12");
ResultSet rs = stmt.executeQuery("select avg(salary) from teacher");
rs.next();
double avg_sal = rs.getDouble(1);
if(avg_sal > 4000){
conn.rollback(sp1);
}else if(avg_sal >= 3000){
conn.rollback(sp2);
}
conn.commit();
rs = stmt.executeQuery("select * from teacher");
while(rs.next()){
System.out.println(rs.getInt(1) + "\t" + rs.getString(2).trim() + "\t" + rs.getDouble(3));
}
rs.close();
stmt.close();
}catch(Exception e){
System.out.println("Failure,rollback!");
try{
conn.rollback();
}catch(Exception e1){
e.printStackTrace();
}
e.printStackTrace();
}finally{
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
批处理
JDBC2.0开始提供了对数据库操作的批处理（Batch Processing）功能，使用批处理功能避免了向数据库进行一连串的调用，从而可以显著提高程序的运行效率。
Statement接口提供的批处理相关方法：
void addBatch(String sql)
int[] executeBatch()
void clearBatch()
drop table teacher; create table teacher(tid number(6), name char(20), salary number(7,2));
import java.sql.*;
public class TestBatch{
public static void main(String[] args){
Connection conn = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
conn.setAutoCommit(false);
Statement stmt = conn.createStatement();
stmt.addBatch("insert into teacher values(11,'Tom',2500)");
stmt.addBatch("insert into teacher values(12,'John',3400)");
stmt.addBatch("insert into teacher values(13,'Billy',3150)");
stmt.addBatch("update teacher set salary = salary + 88");
stmt.executeBatch();
conn.commit();
ResultSet rs = stmt.executeQuery("select * from teacher");
while(rs.next()){
System.out.println(rs.getInt(1) + "\t" + rs.getString(2).trim() + "\t" + rs.getDouble(3));
}
rs.close();
stmt.close();
}catch(Exception e){
System.out.println("Failure,rollback!");
try{
conn.rollback();
}catch(Exception e1){
e.printStackTrace();
}
e.printStackTrace();
}finally{
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
高级SQL类型BLOB/CLOB
高级SQL类型BLOB/CLOB
BLOB（Binary Large OBject，二进制大对象类型用于保存大规模的二进制数据
CLOB（Character Large OBject，文本大对象）类型则用于保存大规模的文本数据
JDBC2.0开始引入了对应于SQL99标准的多种高级数据类型，其中最重要的是两种大对象类型BLOB和CLOB。
使用BLOB类型
drop table Student_List;
create table Student_List(
Student_ID varchar2(20) primary key,
Student_Name varchar2(20) not null,
Student_Pic BLOB
);
import java.sql.*;
import java.io.*;
public class SavePicture{
public static void main(String[] args){
Connection conn = null;
PreparedStatement stmt = null;
FileInputStream fis = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521dbrbh";
conn = DriverManager.getConnection(url, "scott","tiger");
String sql = "insert into Student_List values(?,?,?)";
stmt=conn.prepareStatement(sql);
stmt.setString(1,"s01");
stmt.setString(2,"Youyou");
File file = new File("girl.jpg");
fis = new FileInputStream(file);
stmt.setBinaryStream(3, fis, (int)file.length());
stmt.executeUpdate();
stmt.close();
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(fis!=null){
fis.close();
}
}catch(IOException ioe){
ioe.printStackTrace();
}
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
import java.sql.*;
import java.io.*;
public class GetPicture{
public static void main(String[] args){
PreparedStatement stmt = null;
ResultSet rs = null;
Connection conn = null;
FileOutputStream fos = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url= "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
String sql="select * from Student_List where Student_ID='s01'";
stmt = conn.prepareStatement(sql);
rs = stmt.executeQuery();
rs.next();
File file = new File("d:\\kk.jpg");
fos = new FileOutputStream(file);
InputStream is = rs.getBinaryStream(3);
int len = 0;
byte b[] = new byte[4*1024];
while((len=is.read(b))!=-1)
{
fos.write(b,0,len);
}
fos.flush();
fos.close();
is.close();
rs.close();
stmt.close();
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(fos!=null){
fos.close();
}
}catch(IOException ioe){
ioe.printStackTrace();
}
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
使用CLOB类型
drop table book_list;
create table book_list(
bid varchar2(20) primary key,
name varchar2(40) not null,
content CLOB
);
import java.sql.*;
import java.io.*;
public class SaveClob{
public static void main(String[] args){
Connection conn = null;
PreparedStatement stmt = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url = "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url, "scott","tiger");
String sql = "insert into book_list values(?,?,?)";
stmt=conn.prepareStatement(sql);
stmt.setString(1,"b001");
stmt.setString(2,"99个简单法则");
BufferedReader br = new BufferedReader(new FileReader("a.txt"));
StringBuffer sb = new StringBuffer();
String s;
while((s=br.readLine()) != null){
sb.append(s + "\n");
}
br.close();
String content = sb.toString();
StringReader sr = new StringReader(content);
stmt.setCharacterStream(3, sr, content.length());
stmt.executeUpdate();
sr.close();
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
import java.sql.*;
import java.io.*;
public class GetClob{
public static void main(String[] args){
Connection conn = null;
PreparedStatement stmt = null;
ResultSet rs = null;
FileOutputStream fos = null;
try{
Class.forName("oracle.jdbc.driver.OracleDriver");
String url= "jdbc:oracle:thin:@localhost:1521:dbrbh";
conn = DriverManager.getConnection(url,"scott","tiger");
String sql="select * from book_list where bid='b001'";
stmt = conn.prepareStatement(sql);
rs = stmt.executeQuery();
rs.next();
StringBuffer sb = new StringBuffer();
Reader rd = rs.getCharacterStream(3);
BufferedReader br = new BufferedReader(rd);
String s;
while((s=br.readLine())!=null)
{
sb.append(s + "\n");
}
System.out.println(sb.toString());
rs.close();
br.close();
stmt.close();
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(conn != null){
conn.close();
}
}catch(Exception e){
e.printStackTrace();
}
}
}
}
分享到：
发表评论
-
Json将对象转换成字符串
2010-11-26 22:41 10681最近用到Json传输对象交互,整理一个简单的方法. ... -
应用程序国际化
2010-05-12 20:44 1530基本概念 国际化（Internationalization， ... -
网络编程
2010-05-09 16:46 1815计算机网络基础 什么是计算机网络 把分布在不同地理区域的计 ... -
线 程
2010-05-08 16:22 1475线 程 线程是一个程序内部的顺序控制流 线程和进程 每 ... -
泛 型
2010-05-05 12:42 1746什么是泛型 泛型(Gernerics)机制自java se ... -
Java I/O编程
2010-05-04 20:58 6897java i/o原理 基本概念: I/O(Input/O ... -
集合与映射
2010-05-02 20:22 2339集合框架概述 集合就是将若干用途,性质相同或相见的数组合 ... -
控制台应用程序设计
2010-04-30 16:24 1875命令行参数 在启动时java控制台应用程序,可以一次性地向 ... -
java常用类
2010-04-29 16:33 5024Object类 java.lang.Object类是所有ja ... -
异常的处理
2010-04-27 18:46 1984异常 异常(Exception)是程序运行过程中发生的事件 ... -
高级类特性
2010-04-26 21:42 1013说了开始复习基础了， ... -
java.lang包错误概述
2010-04-15 20:07 2306接口 java.lang.Appendable可追加（app ... -
java对日期的操作技巧
2010-03-30 15:52 1455这篇文章是很早很早存机子上的...也是在哪里看到的然 ... -
MyEclipse6.5安装SVN插件的三种方法
2010-03-18 16:06 1602一、安装方法： 方 ... -
关于java打包问题
2010-03-09 20:25 23191、怎么把一个ｊａｖａ文件打包到当前目录 ｊａｖａc ... -
关于MyEclipse/Eclipse汉化问题
2010-03-07 19:23 1289这个是关于MyEclipse/Eclips ... -
Could not find the main class. Program will exit
2010-03-06 21:07 11336虽然说 ...
相关推荐
全国大学生智能汽车竞赛自2006年起，由教育部高等教育司委托高等学校自动化类教学指导委员会举办，旨在加强学生实践、创新能力和培养团队精神的一项创意性科技竞赛。该竞赛至今已成功举办多届，吸引了众多高校学生的积极参与，此文件为智能车竞赛介绍
字卡v4.3.4 原版 三种UI+关键字卡控制+支持获取用户信息+支持强制关注 集卡模块从一开始的版本到助力版本再到现在的新规则版本。 集卡模块难度主要在于 如何控制各种不同的字卡组合 被粉丝集齐的数量。 如果不控制那么一定会出现超过数量的粉丝集到指定的字卡组合，造成奖品不够的混乱，如果大奖价值高的话，超过数量的粉丝集到大奖后，就造成商家的活动费用超支了。我们冥思苦想如何才能限制集到指定字卡组合的粉丝数，后我们想到了和支付宝一样的选一张关键字卡来进行规则设置的方式来进行限制，根据奖品所需的关键字卡数，设定规则就可以控制每种奖品所需字卡组合被粉丝集到的数量，规则可以在活动进行中根据需要进行修改，活动规则灵活度高。新版的集卡规则，在此次政府发布号的活动中经受了考验，集到指定字卡组合的粉丝没有超出规则限制。有了这个规则限制后，您无需盯着活动，建好活动后就无人值守让活动进行就行了，您只需要时不时来看下蹭蹭上涨的活动数据即可。 被封？ 无需担心，模块内置有防封功能，支持隐藏主域名，显示炮灰域名，保护活动安全进行。 活动准备？ 只需要您有一个认证服务号即可，支持订阅号借用认证服务号来做活动。如果您
出口设备线体程序详解：PLC通讯下的V90控制与开源FB284工艺对象实战指南,出口设备线体程序详解：PLC通讯与V90控制集成，工艺对象与FB284协同工作，开源学习V90控制技能,出口设备1200线体程序，多个plc走通讯，内部有多个v90,采用工艺对象与fb284 共同控制，功能快全部开源，能快速学会v90的控制 ,出口设备; 1200线体程序; PLC通讯; 多个V90; 工艺对象; FB284; 功能开源; V90控制。,V90工艺控制：开源功能快，快速掌握1200线体程序与PLC通讯
基于Arduino与DAC8031的心电信号模拟器资料：心电信号与正弦波的双重输出应用方案,Arduino与DAC8031心电信号模拟器：生成心电信号与正弦波输出功能详解,基于arduino +DAC8031的心电信号模拟器资料，可输出心电信号，和正弦波 ,基于Arduino;DAC8031;心电信号模拟器;输出心电信号;正弦波输出;模拟器资料,基于Arduino与DAC8031的心电信号模拟器：输出心电与正弦波
MATLAB口罩检测的基本流程 图像采集：通过摄像头或其他图像采集设备获取包含面部的图像。 图像预处理：对采集到的图像进行灰度化、去噪、直方图均衡化等预处理操作，以提高图像质量，便于后续的人脸检测和口罩检测。 人脸检测：利用Haar特征、LBP特征等经典方法或深度学习模型（如MTCNN、FaceBoxes等）在预处理后的图像中定位人脸区域。 口罩检测：在检测到的人脸区域内，进一步分析是否佩戴口罩。这可以通过检测口罩的边缘、纹理等特征，或使用已经训练好的口罩检测模型来实现。 结果输出：将检测结果以可视化方式展示，如在图像上标注人脸和口罩区域，或输出文字提示是否佩戴口罩。
1、文件内容：kernel-debug-devel-3.10.0-1160.119.1.el7.rpm以及相关依赖 2、文件形式：tar.gz压缩包 3、安装指令： #Step1、解压 tar -zxvf /mnt/data/output/kernel-debug-devel-3.10.0-1160.119.1.el7.tar.gz #Step2、进入解压后的目录，执行安装 sudo rpm -ivh *.rpm 4、更多资源/技术支持：公众号禅静编程坊
该文档提供了一个关于供应链管理系统开发的详细指南，重点介绍了项目安排、技术实现和框架搭建的相关内容。 文档分为以下几个关键部分： 项目安排：主要步骤包括搭建框架（1天），基础数据模块和权限管理（4天），以及应收应付和销售管理（5天）。 供应链概念：供应链系统的核心流程是通过采购商品放入仓库，并在销售时从仓库提取商品，涉及三个主要订单：采购订单、销售订单和调拨订单。 大数据的应用：介绍了数据挖掘、ETL（数据抽取）和BI（商业智能）在供应链管理中的应用。 技术实现：讲述了DAO（数据访问对象）的重用、服务层的重用、以及前端JS的继承机制、jQuery插件开发等技术细节。 系统框架搭建：包括Maven环境的配置、Web工程的创建、持久化类和映射文件的编写，以及Spring配置文件的实现。 DAO的需求和功能：供应链管理系统的各个模块都涉及分页查询、条件查询、删除、增加、修改操作等需求。 泛型的应用：通过示例说明了在Java语言中如何使用泛型来实现模块化和可扩展性。 文档非常技术导向，适合开发人员参考，用于构建供应链管理系统的架构和功能模块。
1.版本：matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点：参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象：计算机，电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
C#与VB实现欧姆龙PLC的Fins TCP通信案例源码：调用动态链接库进行数据读写，定时器与计数器数据区的简洁读写操作示例,C#与VB实现欧姆龙PLC的Fins TCP通信案例源码：调用动态链接库进行读写操作，涵盖定时器计数器数据区学习案例,C#欧姆龙plc Fins Tcp通信案例上位机源码，有c#和VB的Demo，c#上位机和欧姆龙plc通讯案例源码,调用动态链接库，可以实现上位机的数据连接，可以简单实现D区W区定时器计数器等数据区的读写，是一个非常好的学习案例 ,C#; 欧姆龙PLC; Fins Tcp通信; 上位机源码; 动态链接库; 数据连接; D区W区读写; 定时器计数器; 学习案例,C#实现欧姆龙PLC Fins Tcp通信上位机源码，读写数据区高效学习案例
可调谐石墨烯超材料吸收体的FDTD仿真模拟研究报告：吸收光谱的化学势调节策略与仿真源文件解析,可调谐石墨烯超材料吸收体：化学势调节光谱的FDTD仿真模拟研究,可调谐石墨烯超材料吸收体FDTD仿真模拟 【案例内容】该案例提供了一种可调谐石墨烯超材料吸收体，其吸收光谱可以通过改变施加于石墨烯的化学势来进行调节。 【案例文件】仿真源文件 ,可调谐石墨烯超材料吸收体; FDTD仿真模拟; 化学势调节; 仿真源文件,石墨烯超材料吸收体：FDTD仿真调节吸收光谱案例解析
RBF神经网络控制仿真-第二版
松下PLC与威纶通触摸屏转盘设备控制：FPWINPRO7与EBPRO智能编程与宏指令应用,松下PLC与威纶通触摸屏转盘设备控制解决方案：FPWINPRO7与EBPRO协同工作，实现多工位转盘加工与IEC编程模式控制,松下PLC+威纶通触摸屏的转盘设备 松下PLC工程使用程序版本为FPWINPRO7 7.6.0.0版本 威纶通HMI工程使用程序版本为EBPRO 6.07.02.410S 1.多工位转盘加工控制。 2.国际标准IEC编程模式。 3.触摸屏宏指令应用控制。 ,松下PLC; 威纶通触摸屏; 转盘设备控制; 多工位加工控制; IEC编程模式; 触摸屏宏指令应用,松下PLC与威纶通HMI联控的转盘设备控制程序解析
基于循环神经网络（RNN）的多输入单输出预测模型（适用于时间序列预测与回归分析，需Matlab 2021及以上版本）,基于循环神经网络（RNN）的多输入单输出预测模型（matlab版本2021+），真实值与预测值对比，多种评价指标与线性拟合展示。,RNN预测模型做多输入单输出预测模型，直接替数据就可以用。 程序语言是matlab，需求最低版本为2021及以上。 程序可以出真实值和预测值对比图，线性拟合图，可打印多种评价指标。 PS:以下效果图为测试数据的效果图，主要目的是为了显示程序运行可以出的结果图，具体预测效果以个人的具体数据为准。 2.由于每个人的数据都是独一无二的，因此无法做到可以任何人的数据直接替就可以得到自己满意的效果。 这段程序主要是一个基于循环神经网络（RNN）的预测模型。它的应用领域可以是时间序列预测、回归分析等。下面我将对程序的运行过程进行详细解释和分析。 首先，程序开始时清空环境变量、关闭图窗、清空变量和命令行。然后，通过xlsread函数导入数据，其中'数据的输入'和'数据的输出'是两个Excel文件的文件名。 接下来，程序对数据进行归一化处理。首先使用ma
1.版本：matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点：参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象：计算机，电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。
旅游管理系统中的功能模块主要是实现管理员；首页、个人中心、用户管理、旅游方案管理、旅游购买管理、系统管理，用户；首页、个人中心、旅游方案管理、旅游购买管理、我的收藏管理。前台首页；首页、旅游方案、旅游资讯、个人中心、后台管理等功能。经过认真细致的研究，精心准备和规划，最后测试成功，系统可以正常使用。分析功能调整与旅游管理系统实现的实际需求相结合，讨论了Java开发旅游管理系统的使用。 从上面的描述中可以基本可以实现软件的功能： 1、开发实现旅游管理系统的整个系统程序； 2、管理员；首页、个人中心、用户管理、旅游方案管理、旅游购买管理、系统管理等。 3、用户：首页、个人中心、旅游方案管理、旅游购买管理、我的收藏管理。 4、前台首页：首页、旅游方案、旅游资讯、个人中心、后台管理等相应操作； 5、基础数据管理：实现系统基本信息的添加、修改及删除等操作，并且根据需求进行交流查看及回复相应操作。
Boost二级升压光伏并网结构的Simulink建模与MPPT最大功率点追踪：基于功率反馈的扰动观察法调整电压方向研究,Boost二级升压光伏并网结构的Simulink建模与MPPT最大功率点追踪：基于功率反馈的扰动观察法调整电压方向研究,Boost二级升压光伏并网结构，Simulink建模，MPPT最大功率点追踪，扰动观察法采用功率反馈方式，若ΔP>0，说明电压调整的方向正确，可以继续按原方向进行“干扰”；若ΔP<0，说明电压调整的方向错误，需要对“干扰”的方向进行改变。 ,Boost升压;光伏并网结构;Simulink建模;MPPT最大功率点追踪;扰动观察法;功率反馈;电压调整方向。,光伏并网结构中Boost升压MPPT控制策略的Simulink建模与功率反馈扰动观察法
运行GUI版本，可二开
Deepseek相关主题资源及行业影响
WP Smush Pro 是一款专为 WordPress 网站设计的图像优化插件。 一、主要作用 图像压缩 它能够在不影响图像质量的前提下，大幅度减小图像文件的大小。例如，对于一些高分辨率的产品图片或者风景照片，它可以通过先进的压缩算法，去除图像中多余的数据。通常 JPEG 格式的图像经过压缩后，文件大小可以减少 40% – 70% 左右。这对于网站性能优化非常关键，因为较小的图像文件可以加快网站的加载速度。 该插件支持多种图像格式的压缩，包括 JPEG、PNG 和 GIF。对于 PNG 图像，它可以在保留透明度等关键特性的同时，有效地减小文件尺寸。对于 GIF 图像，也能在一定程度上优化文件大小，减少动画 GIF 的加载时间。 懒加载 WP Smush Pro 实现了图像懒加载功能。懒加载是一种延迟加载图像的技术，当用户滚动页面到包含图像的位置时，图像才会加载。这样可以避免一次性加载大量图像，尤其是在页面内容较多且包含许多图像的情况下。例如，在一个新闻网站的长文章页面，带有大量配图，懒加载可以让用户在浏览文章开头部分时，不需要等待所有图片加载，从而提高页面的初始加载速度，同时也能
Could not create share link. Missing file: C:\Users\xx\.conda\envs\omni\Lib\site-packages\gradio\frpc_windows_amd64_v0.3 1. Download this file: https://cdn-media.huggingface.co/frpc-gradio-0.3/frpc_windows_amd64.exe 2. Rename the downloaded file to: frpc_windows_amd64_v0.3 3. Move the file to this location: C:\Users\xx\.conda\envs\omni\Lib\site-packages\gradio