当前位置： 首页 > news >正文

java_JDBC(4)

news 来源：原创 2024/5/14 15:42:26

一、Statement

import java.sql.*;  
  
public class TestJDBC {  
  
    public static void main(String[] args) {  
        Connection oracle_conn = null;  
        Statement oracle_stmt = null;  
        ResultSet oracle_rs = null;  
          
        Connection mssql_conn = null;  
        Statement mssql_stmt = null;  
        ResultSet mssql_rs = null;  
                  
        try {  
            Class.forName("oracle.jdbc.driver.OracleDriver");  
            oracle_conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.215:1521:orcl", "username", "password");  
              
            oracle_stmt = oracle_conn.createStatement();  
              
            Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");  
            mssql_conn = DriverManager.getConnection("jdbc:sqlserver://192.168.0.213:1433;DatabaseName=VIS", "username", "password");  
              
            mssql_stmt = mssql_conn.createStatement();  
            mssql_rs = mssql_stmt.executeQuery("select * from VideoBaseInfo");  
              
            while(mssql_rs.next()) {  
                System.out.println("正在插入VideoId：" + mssql_rs.getInt("VideoId") + "的记录...");  
                oracle_stmt.executeUpdate("insert into VIDEO_BASEINFO values("   
                        + mssql_rs.getInt("VideoId") + ",'"  
                        + mssql_rs.getString("VideoName") + "','"  
                        + mssql_rs.getString("VideoVersion") + "',"  
                        + mssql_rs.getInt("VideoMp4Items") + ","  
                        + mssql_rs.getInt("VideoRmvbItems") + ",'"  
                        + mssql_rs.getString("VideoAliasName") + "','"  
                        + mssql_rs.getString("VideoAge") + "'"  
                        + ")");  
            }  
              
        } catch (ClassNotFoundException e) {  
            e.printStackTrace();  
        } catch (SQLException e) {  
            e.printStackTrace();  
        } finally {  
            try {  
                if(oracle_rs != null) {  
                    oracle_rs.close();  
                    oracle_rs = null;  
                }  
                  
                if(oracle_stmt != null) {  
                    oracle_stmt.close();  
                    oracle_stmt = null;  
                }  
                  
                if(oracle_conn != null) {  
                    oracle_conn.close();  
                    oracle_conn = null;  
                }  
                  
                if(mssql_rs != null) {  
                    mssql_rs.close();  
                    mssql_rs = null;  
                }  
                  
                if(mssql_stmt != null) {  
                    mssql_stmt.close();  
                    mssql_stmt = null;  
                }  
                  
                if(mssql_conn != null) {  
                    mssql_conn.close();  
                    mssql_conn = null;  
                }  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
    }  
  
}  
import java.sql.*;

public class TestJDBC {

	public static void main(String[] args) {
		Connection oracle_conn = null;
		Statement oracle_stmt = null;
		ResultSet oracle_rs = null;
		
		Connection mssql_conn = null;
		Statement mssql_stmt = null;
		ResultSet mssql_rs = null;
				
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			oracle_conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.215:1521:orcl", "username", "password");
			
			oracle_stmt = oracle_conn.createStatement();
			
			Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
			mssql_conn = DriverManager.getConnection("jdbc:sqlserver://192.168.0.213:1433;DatabaseName=VIS", "username", "password");
			
			mssql_stmt = mssql_conn.createStatement();
			mssql_rs = mssql_stmt.executeQuery("select * from VideoBaseInfo");
			
			while(mssql_rs.next()) {
				System.out.println("正在插入VideoId：" + mssql_rs.getInt("VideoId") + "的记录...");
				oracle_stmt.executeUpdate("insert into VIDEO_BASEINFO values(" 
						+ mssql_rs.getInt("VideoId") + ",'"
						+ mssql_rs.getString("VideoName") + "','"
						+ mssql_rs.getString("VideoVersion") + "',"
						+ mssql_rs.getInt("VideoMp4Items") + ","
						+ mssql_rs.getInt("VideoRmvbItems") + ",'"
						+ mssql_rs.getString("VideoAliasName") + "','"
						+ mssql_rs.getString("VideoAge") + "'"
						+ ")");
			}
			
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if(oracle_rs != null) {
					oracle_rs.close();
					oracle_rs = null;
				}
				
				if(oracle_stmt != null) {
					oracle_stmt.close();
					oracle_stmt = null;
				}
				
				if(oracle_conn != null) {
					oracle_conn.close();
					oracle_conn = null;
				}
				
				if(mssql_rs != null) {
					mssql_rs.close();
					mssql_rs = null;
				}
				
				if(mssql_stmt != null) {
					mssql_stmt.close();
					mssql_stmt = null;
				}
				
				if(mssql_conn != null) {
					mssql_conn.close();
					mssql_conn = null;
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

}

 二、PreparedStatement

import java.sql.*;

public class TestPreparedStatement {

	public static void main(String[] args) {
		Connection oracle_conn = null;
		PreparedStatement oracle_stmt = null;
		ResultSet oracle_rs = null;
		
		Connection mssql_conn = null;
		Statement mssql_stmt = null;
		ResultSet mssql_rs = null;
				
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			oracle_conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.215:1521:orcl", "username", "password");
			
			oracle_stmt = oracle_conn.prepareStatement("insert into Video_ItemInfo values(?, ?, ?, ?, ?, ?, ?, ?, ?)");
			
			Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
			mssql_conn = DriverManager.getConnection("jdbc:sqlserver://192.168.0.213:1433;DatabaseName=VIS", "username", "password");

			mssql_stmt = mssql_conn.createStatement();
			mssql_rs = mssql_stmt.executeQuery("select * from VideoItemInfo");
			
			while(mssql_rs.next()) {
				System.out.println("正在插入ItemIndex：" + mssql_rs.getInt("ItemIndex") + "的记录...");
				oracle_stmt.setInt(1, mssql_rs.getInt("ItemIndex"));
				oracle_stmt.setInt(2, mssql_rs.getInt("VideoId"));
				oracle_stmt.setString(3, mssql_rs.getString("VideoItemName"));
				oracle_stmt.setString(4, mssql_rs.getString("VideoExtName"));
				oracle_stmt.setDouble(5, mssql_rs.getDouble("VideoSize"));
				oracle_stmt.setString(6, mssql_rs.getString("VideoPath"));
				oracle_stmt.setString(7, mssql_rs.getString("VideoType"));
				oracle_stmt.setDate(8, mssql_rs.getDate("VideoDate"));
				oracle_stmt.setString(9, mssql_rs.getString("ApplicationWay"));
				
				oracle_stmt.executeUpdate();
			}
			System.out.println("插入数据到Video_ItemInfo表中操作已完成！");
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if(oracle_rs != null) {
					oracle_rs.close();
					oracle_rs = null;
				}
				
				if(oracle_stmt != null) {
					oracle_stmt.close();
					oracle_stmt = null;
				}
				
				if(oracle_conn != null) {
					oracle_conn.close();
					oracle_conn = null;
				}
				
				if(mssql_rs != null) {
					mssql_rs.close();
					mssql_rs = null;
				}
				
				if(mssql_stmt != null) {
					mssql_stmt.close();
					mssql_stmt = null;
				}
				
				if(mssql_conn != null) {
					mssql_conn.close();
					mssql_conn = null;
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

}

 

三、CallableStatement

import java.sql.*;
public class TestProc {

	/**
	 * @param args
	 */
	public static void main(String[] args) throws Exception {
		
		Class.forName("oracle.jdbc.driver.OracleDriver");
		Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.1:1521:SXT", "scott", "tiger");
		CallableStatement cstmt = conn.prepareCall("{call p(?, ?, ?, ?)}");
		cstmt.registerOutParameter(3, Types.INTEGER);
		cstmt.registerOutParameter(4, Types.INTEGER);
		cstmt.setInt(1, 3);
		cstmt.setInt(2, 4);
		cstmt.setInt(4, 5);
		cstmt.execute();
		System.out.println(cstmt.getInt(3));
		System.out.println(cstmt.getInt(4));
		cstmt.close();
		conn.close();
	}

}

 

四、Batch

import java.sql.*;
public class TestBatch {


	public static void main(String[] args) throws Exception {
		Class.forName("oracle.jdbc.driver.OracleDriver");
		Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.1:1521:SXT", "scott", "tiger");
		/*
		Statement stmt = conn.createStatement();
		stmt.addBatch("insert into dept2 values (51, '500', 'haha')");
		stmt.addBatch("insert into dept2 values (52, '500', 'haha')");
		stmt.addBatch("insert into dept2 values (53, '500', 'haha')");
		stmt.executeBatch();
		stmt.close();
		*/
		
		PreparedStatement ps = conn.prepareStatement("insert into dept2 values (?, ?, ?)");
		ps.setInt(1, 61);
		ps.setString(2, "haha");
		ps.setString(3, "bj");
		ps.addBatch();
		
		ps.setInt(1, 62);
		ps.setString(2, "haha");
		ps.setString(3, "bj");
		ps.addBatch();
		
		ps.setInt(1, 63);
		ps.setString(2, "haha");
		ps.setString(3, "bj");
		ps.addBatch();
		
		ps.executeBatch();
		ps.close();
		
		conn.close();

	}

}

 

五、Transaction

import java.sql.*;
public class TestTransaction {


	public static void main(String[] args) {
		
		Connection conn = null;
		Statement stmt = null;
		
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:SXT", "scott", "tiger");
			
			conn.setAutoCommit(false);
			stmt = conn.createStatement();
			stmt.addBatch("insert into dept2 values (51, '500', 'haha')");
			stmt.addBatch("insert into dept2 values (52, '500', 'haha')");
			stmt.addBatch("insert into dept2 values (53, '500', 'haha')");
			stmt.executeBatch();
			conn.commit();
			conn.setAutoCommit(true);
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		} catch(SQLException e) {
			
			e.printStackTrace();
			
			try {
				if(conn != null)
				{
					conn.rollback();
					conn.setAutoCommit(true);
				}
			} catch (SQLException e1) {
				e1.printStackTrace();
			}
		}finally {
			try {
				if(stmt != null)
					stmt.close();
				if(conn != null)
					conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		

	}

}

 

六、ScrollResultSet

import java.sql.*;

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

		try {
			new oracle.jdbc.driver.OracleDriver();
			String url = "jdbc:oracle:thin:@192.168.0.1:1521:SXT";
			Connection conn = DriverManager
					.getConnection(url, "scott", "tiger");
			Statement stmt = conn.createStatement(
					ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			ResultSet rs = stmt
					.executeQuery("select * from emp order by sal");
			rs.next();
			System.out.println(rs.getInt(1));
			rs.last();
			System.out.println(rs.getString(1));
			System.out.println(rs.isLast());
			System.out.println(rs.isAfterLast());
			System.out.println(rs.getRow());
			rs.previous();
			System.out.println(rs.getString(1));
			rs.absolute(6);
			System.out.println(rs.getString(1));
			rs.close();
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}

 七、UpdateResultSet

import java.sql.*;
public class TestUpdataRs {
    public static void main(String args[]){
	
	try{
	    new oracle.jdbc.driver.OracleDriver();
	    String url="jdbc:oracle:thin:@192.168.0.1:1521:SXT";
	    Connection conn=DriverManager.getConnection(url,"scott","tiger");
	    Statement stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
	    
	    ResultSet rs=stmt.executeQuery("select * from emp2");
	    
	    rs.next();
	    //更新一行数据
	    rs.updateString("ename","AAAA");
	    rs.updateRow();

	    //插入新行
	    rs.moveToInsertRow();
	    rs.updateInt(1, 9999);
	    rs.updateString("ename","AAAA");
	    rs.updateInt("mgr", 7839);
	    rs.updateDouble("sal", 99.99);
	    rs.insertRow();
	    //将光标移动到新建的行
	    rs.moveToCurrentRow();

	    //删除行
	    rs.absolute(5);
	    rs.deleteRow();

	    //取消更新
	    //rs.cancelRowUpdates();

	  }catch(SQLException e){
	    e.printStackTrace();
	  }
    }
}

 

转载于:https://www.cnblogs.com/caroline4lc/p/4611417.html

相关文章：

  • svnserver搭建
  • Android视图绘制流程完全解析，带你一步步深入了解View(二)
  • OTS工作坑
  • GDB调试详解
  • Tomcat和JavaWeb目录和流程
  • 采访与书评 —— 《BDD In Action》
  • android下拉刷新
  • AOP之AspectJ注解
  • httpclient-4.0.1应用指南
  • 05-树7 堆中的路径
  • 初识 Swift编程语言（中文版)
  • Learning WCF Chapter1 Creating a New Service from Scratch
  • Navicat Premium快速导出数据库ER图和数据字典
  • java存取BLOB类型的数据
  • [WebGL入门]二十五，点光源的光照
  • [ 一起学React系列 -- 8 ] React中的文件上传
  • 【Linux系统编程】快速查找errno错误码信息
  • 【划重点】MySQL技术内幕：InnoDB存储引擎
  • cookie和session
  • Fastjson的基本使用方法大全
  • HashMap剖析之内部结构
  • Nacos系列：Nacos的Java SDK使用
  • nginx 负载服务器优化
  • Phpstorm怎样批量删除空行？
  • 基于axios的vue插件，让http请求更简单
  • ------- 计算机网络基础
  • 解决iview多表头动态更改列元素发生的错误
  • 老板让我十分钟上手nx-admin
  • 前端攻城师
  • 十年未变！安全，谁之责？（下）
  • 使用SAX解析XML
  • 说说动画卡顿的解决方案
  • 看到一个关于网页设计的文章分享过来！大家看看！
  • ​软考-高级-系统架构设计师教程（清华第2版）【第12章 信息系统架构设计理论与实践（P420~465）-思维导图】​
  • #我与Java虚拟机的故事#连载01：人在JVM，身不由己
  • （1）安装hadoop之虚拟机准备（配置IP与主机名）
  • （附程序）AD采集中的10种经典软件滤波程序优缺点分析
  • （附源码）python旅游推荐系统 毕业设计 250623
  • （附源码）spring boot球鞋文化交流论坛 毕业设计 141436
  • (数位dp) 算法竞赛入门到进阶 书本题集
  • （四）Android布局类型（线性布局LinearLayout）
  • (原創) 未来三学期想要修的课 (日記)
  • （自用）learnOpenGL学习总结-高级OpenGL-抗锯齿
  • *1 计算机基础和操作系统基础及几大协议
  • ./configure,make,make install的作用(转)
  • .NET Core WebAPI中使用Log4net 日志级别分类并记录到数据库
  • .net 程序发生了一个不可捕获的异常
  • .NET/C# 中设置当发生某个特定异常时进入断点（不借助 Visual Studio 的纯代码实现）
  • .net6Api后台+uniapp导出Excel
  • .net流程开发平台的一些难点（1）
  • .NET企业级应用架构设计系列之结尾篇
  • @RequestMapping-占位符映射
  • [ C++ ] STL---string类的使用指南
  • [.net 面向对象程序设计进阶] (19) 异步(Asynchronous) 使用异步创建快速响应和可伸缩性的应用程序...
  • [AutoSar]BSW_Com07 CAN报文接收流程的函数调用