扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 数据库 >Java40: 数据库四(Oracle)
  • 387

0
分享到

Java40: 数据库四(Oracle)

2024-04-02 19:04:59 387人浏览 独家记忆
摘要

JDBC 提供访问数据库的标准  就是一系列接口 定义了访问数据库的通用的方法由各个数据库厂商提供对JDBC的实现JDBC接口的定义数据库厂商对jdbc的实现 jar建立连接-发送sql-执行sq

JDBC 提供访问数据库的标准  就是一系列接口 定义了访问数据库的通用的方法

由各个数据库厂商提供对JDBC的实现


JDBC接口的定义

数据库厂商对jdbc的实现 jar


建立连接-发送sql-执行sql-返回结果-关闭连接


JDBC api（接口）

    java.sql.Connection//封装和数据库的连接

    java.sql.Statement//封装SQL语句的执行

    jave.sql.ResultSet//封装DQL执行的结果

package jdbc;

import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import oracle.jdbc.OracleDriver;

public class OracleDemo01 {
	public static void main(String[] args) throws Exception{
		//装载JDBC的实现
		
		//Driver driver =new OracleDriver() ; 自己写
		//DriverManager.reGISterDriver(driver);
		
		//把类装载到内存中  静态 快中执行  上面的两条  就不用自己写了
		//该类的静态块中的代码会进行Driver的注册
		Class.forName("oracle.jdbc.OracleDriver");//装载JDBC的实现用这个就好了
		
		//创建连接
		//调用DriverManager 的getConnection方法
		//该方法返回的是数据库厂商对Connection接口的实现类的对象(因为DriverManager已经注册了数据库厂商的Driver信息)
		String url = "jdbc:oracle:thin:@x1.zongxuan.online:1521:xx";
		String user = "scott";
		String pass = "xxxxx";
		Connection con = DriverManager.getConnection(url,user,pass);
														//url 用于表示数据库的连接信息(ip port 数据库名称)  不同的数据库厂商有特定的url的格式和标识
														// DriverManager 会根据这个标识来选取不同的驱动信息
														//如果同时注册了多个数据库厂商的实现
																			//user
																						//passWord
		//System.out.println(con);
		//执行SQL
		//Connection 的createStatement() 方法用于创建Statement 实现类的对象
		Statement stmt = con.createStatement();
			//只能执行DQL语句
			//返回值是ResultSet
			//把SQl语句传输给数据库执行
		    //获取数据库传输会的结果数据
		    //并把这个数据封装成ResultSet 对象
		ResultSet rs = stmt.executeQuery("select empno,ename name,sal from emp");
		//获取结果
		while(rs.next()){//.next() 游标 向下
			System.out.println(rs.getString("empno")+","+rs.getString("name")+","+rs.getString("sal"));
		}
		rs.close();
		//关闭连接
		
		
	} 
}
package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class OracleDemo02 {
	public static void main(String[] args) throws Exception{
		Class.forName("oracle.jdbc.OracleDriver");
		String url = "jdbc:oracle:thin:@x1.zongxuan.online:1521:xx";
		String user="scott";
		String pass="xxxxx";
		Connection con = DriverManager.getConnection(url,user,pass);
		Statement stmt = con.createStatement();
		//执行DML语句 insert delete update
		String sql = "insert into emp2(empno,ename,sal,deptno) values(20,'lmdtx',3000,10)";
		int n = stmt.executeUpdate(sql);//返回整数表示，刚才的语句影响的行数
		System.out.println(n);
		con.close();
	}
}
package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class OracleDemo03 {
	public static void main(String[] args) throws Exception{
		Class.forName("oracle.jdbc.OracleDriver");
		String url = "jdbc:oracle:thin:@x1.zongxuan.online:1521:xx";
		String user = "scott";
		String pass = "xxxxx";
		Connection con = DriverManager.getConnection(url,user,pass);
		Statement stmt = con.createStatement();
		String sql = "delete from emp2 where ename='lmdtx'";
		int n = stmt.executeUpdate(sql);
		System.out.println(n);
		con.close();
	}
}



会有被注入的风险

name:a' or 'b'='b
a' or 'b'='b
select ename,empno,sal from emp2 where ename = 'a' or 'b'='b'
package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Scanner;

public class OracleDemo04 {
	public static void main(String[] args) throws Exception{
		Scanner in = new Scanner(System.in);
		System.out.print("name:");
		String name = in.nextLine();
		System.out.println(name);
		Class.forName("oracle.jdbc.OracleDriver");
		String url = "jdbc:oracle:thin:@x1.zongxuan.online:1521:xx";
		String user = "scott";
		String pass = "xxxxx";
		Connection con = DriverManager.getConnection(url,user,pass);
		Statement stat = con.createStatement();
		String sql ="select ename,empno,sal from emp2 where ename = '"+name+"'";
		System.out.println(sql);
		ResultSet rs = stat.executeQuery(sql);
		while(rs.next()){
			System.out.println(rs.getString(1)+","+rs.getInt(2)+","+rs.getInt(3));
		}
		con.close();
	}
}

PreparedStatement 接口（用这个好）

  提高效率

  防止SQL Injection

    1创建连接

    2PreparedStatement

        PreparedStatement stmt = con.prepareStatement(sql)

    3 stmt.setString(1,"xxx");

     stmt.setInt(1,123);

package jdbc;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class OracleDemo05 {
	public static void main(String[] args)throws Exception{
		BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
		System.out.println("name:");
		String name = br.readLine();
		Class.forName("oracle.jdbc.OracleDriver");
		String url = "jdbc:oracle:thin:@x1.zongxuan.online:1521:xx";
		String user = "scott";
		String pass = "xxxxx";
		Connection con = DriverManager.getConnection(url,user,pass);
		String sql = "select empno,ename,sal from emp2 where ename=?";
		PreparedStatement stmt = con.prepareStatement(sql);
		//将 sql 中 第一个问号的值设置为字符串 
		stmt.setString(1,name);
		ResultSet rs = stmt.executeQuery();
		while(rs.next()){
			System.out.println(rs.getInt(1)+","+rs.getString(2)+","+rs.getInt(3));
		}
		con.close();
		
	}
}

    

package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

public class OracleDemo06 {
	public static void main(String[] args) throws Exception{
		Class.forName("oracle.jdbc.OracleDriver");
		String url ="jdbc:oracle:thin:@x1.zongxuan.online:1521:xx";
		String user ="scott";
		String pass = "xxxxx";
		Connection con = DriverManager.getConnection(url,user,pass);
		String sql ="insert into emp2(empno,ename) values(?,?)";
		PreparedStatement stmt = con.prepareStatement(sql);
		int n =0;
		for(int i =1000;i<3000;i++){
			stmt.setInt(1, i+1);
			stmt.setString(2, "sting"+i);
			n = stmt.executeUpdate();
			System.out.println(i+","+n);
		}
		con.close();
		
	}
}


封装连接工具类

properties 

    文本文件， 存放的是KEY—VALUSE

driver=oracle.jdbc.OracleDriver
url=jdbc:oracle:thin:@x1.zongxuan.online:1521:xx
user=scott
pass=xxxxx
package jdbc;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;

public class DBUtils {
	private static String driver;
	private static String url;
	private static String user;
	private static String pass;
	
	static{
		Properties props = new Properties();
		try {
			props.load(DBUtils.class.getClassLoader().getResourceAsStream("jdbc/db.properties"));
			driver= props.getProperty("driver");
			url= props.getProperty("url");
			user= props.getProperty("user");
			pass= props.getProperty("pass");
			Class.forName(driver);
		} catch (IOException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}
	
	public static Connection openConnection() throws Exception{
		return DriverManager.getConnection(url,user,pass);
	}
}
package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class OracleDemo08 {
	public static void main(String[] args) throws Exception {
		Connection con = DBUtils.openConnection();
		String sql = "select empno,ename,sal from emp2";
		PreparedStatement stmt = con.prepareStatement(sql);
		// 将 sql 中 第一个问号的值设置为字符串

		ResultSet rs = stmt.executeQuery();
		while (rs.next()) {
			System.out.println(rs.getInt(1) + "," + rs.getString(2) + ","
					+ rs.getInt(3));
		}
		con.close();
	}
}


日期

package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Date;

public class Oracledemo09 {
	public static void main(String[] args) throws Exception{
		Connection con = DBUtils.openConnection();
		String sql ="insert into emp2(empno,ename,hiredate)"
				+ "values(?,?,?)";
		PreparedStatement stmt =con.prepareStatement(sql);
		stmt.setInt(1, 4000);
		stmt.setString(2,"lmdtx");
		stmt.setDate(3,new Date(System.currentTimeMillis()));
		int n =stmt.executeUpdate();
		System.out.println(n);
		con.close();
	}
}



批处理

    Batch 处理 批量的插入 更新

    stmt.addBatch();

        把刚刚设置好的数据添加批处理缓冲

    stmt

        执行批处理，把缓冲的数据一次传送给数据库执行

    

    缓存的批处理量受到哭护短JVM内存的限制要指定一个合理的批量值才好

package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;


public class OracleDemo10 {
	public static void main(String[] args) throws Exception{
		Connection con = DBUtils.openConnection();
		String sql = "insert into emp2(empno,ename) values(?,?)";
		PreparedStatement stmt = con.prepareStatement(sql);
		//批量插入
		for(int i =5000;i<=6000;i++){
			stmt.setInt(1, i);
			stmt.setString(2, "M"+i);
			stmt.addBatch();//添加批处理
		}
		stmt.executeBatch();//执行批处理
		con.close();
	}
}
package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;


public class OracleDemo10 {
	public static void main(String[] args) throws Exception{
		Connection con = DBUtils.openConnection();
		String sql = "insert into emp100(id,name) values(?,?)";
		PreparedStatement stmt = con.prepareStatement(sql);
		//批量插入
		for(int i =1;i<=2000000;i++){
			stmt.setInt(1, i);
			stmt.setString(2, "M"+i);
			stmt.addBatch();//添加批处理
			if(i%20000==0){
				stmt.executeBatch();
			}
		}
		stmt.executeBatch();//执行批处理
		con.close();
	}
}



JDBC的事物操作

    JDBC 中所有的DML会默认提交 在每条DML语句后会默认的加入commit


    con.setAutoCommit(false)

    con.commit();//成功

    con.rollback();//失败

    提交事务使用 连接的api

    


测试 表 pay id 10 和id 100 

id 10 的人向 id 100 的人 转账500

create table pay(
  id number(10),
  money number(10)
);
insert into pay values(10,20000);
insert into pay values(100,10000);

select * from pay;
package jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class OracleDemo11 {
	public static void main(String[] args) throws Exception {
		Connection con = DBUtils.openConnection();
		PreparedStatement stmt = con.prepareStatement("update pay set money = money-500 where id=10");
		int n = stmt.executeUpdate();
		System.out.println(n+"行"+"id = 10  money -500");
		if (true) {
			throw new Exception("模仿异常");
		}
		PreparedStatement stmt2 = con.prepareStatement("update pay set money = money+500 where id=100");
		stmt2.executeUpdate();
		System.out.println("id = 100 money +500");
		con.close();
	}
}

 这个就会有异常， id =10的钱被-了500 但是id =100 的却没有+500


使用con.setAutoCommit(false)

package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class OracleDemo12 {
	public static void main(String[] args) throws Exception{
		Connection con =null;
		try{
		con = DBUtils.openConnection();
		con.setAutoCommit(false);
		PreparedStatement stmt = con.prepareStatement("update pay set money = money-500 where id=10");
		int n  = stmt.executeUpdate();
		System.out.println(n+"行"+"id = 10  money -500");
		if (true) {
			throw new Exception("模仿异常");
		}
		PreparedStatement stmt2 = con.prepareStatement("update pay set money = money+500 where id=100");
		stmt2.executeUpdate();
		System.out.println("id = 100 money +500");
		con.commit();
		}catch(Exception e){
			con.rollback();
			e.printStackTrace();
		}
		finally{
		    if(con!=null){
			con.close();
		    }
		}
		

	}
}
package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class OracleDemo12 {
	public static void main(String[] args) throws Exception{
		Connection con =null;
		try{
		con = DBUtils.openConnection();
		con.setAutoCommit(false);
		PreparedStatement stmt = con.prepareStatement("update pay set money = money-500 where id=10");
		int n  = stmt.executeUpdate();
		System.out.println(n+"行"+"id = 10  money -500");
		PreparedStatement stmt2 = con.prepareStatement("update pay set money = money+500 where id=100");
		stmt2.executeUpdate();
		System.out.println("id = 100 money +500");
		con.commit();
		}catch(Exception e){
			con.rollback();
			e.printStackTrace();
		}
		finally{
		    if(con!=null){
			con.close();
		    }
		}
		

	}
}



连接池技术

    别自己写 用开源的  

    Oracle 

        WEBlogic 

    阿里

          Druid 

    Apache Commons

        DBCP

        POOL

        LOGGING



    连接池是一个软件 管理一系列已经建立好的连接 可以节省连接频繁建立的开销，一些牛X的连接池还可以根据当时的用户访问量动态的改变所管理连接的数目

    在应用了连接池以后

    con.close（）

    只是将连接 还给连接池，不在是真正的关闭掉了

    

package jdbc;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;

import org.apache.commons.dbcp2.BasicDataSource;

public class DBUtils2 {
	private static String driver;
	private static String url;
	private static String user;
	private static String pass;
	private static BasicDataSource ds;
	
	static{
		Properties props = new Properties();
		try {
			props.load(DBUtils.class.getClassLoader().getResourceAsStream("jdbc/db.properties"));
			driver= props.getProperty("driver");
			url= props.getProperty("url");
			user= props.getProperty("user");
			pass= props.getProperty("pass");
			ds = new BasicDataSource();
			ds.setDriverClassName(driver);
			ds.setUrl(url);
			ds.setUsername(user);
			ds.setPassword(pass);
		} catch (IOException e) {
			e.printStackTrace();
		} 
	}
	
	public static Connection getConnection() throws Exception{
		return ds.getConnection();
	}
}
package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;


public class OracleDemo13 {
	public static void main(String[] args) throws Exception{
		Connection con = DBUtils2.getConnection();
		String sql = "insert into emp100(id,name) values(?,?)";
		PreparedStatement stmt = con.prepareStatement(sql);
		//批量插入
		for(int i =1;i<=10000000;i++){
			stmt.setInt(1, i);
			stmt.setString(2, "M"+i);
			stmt.addBatch();//添加批处理
			if(i%20000==0){
				stmt.executeBatch();
				System.out.println(i);
			}
		}
		stmt.executeBatch();//执行批处理
		con.close();
	}
}


DAO 

    Data Access Object

 专门用来访问数据库的程序=》 数据访问层 （Data Access Layer） 



    1》实体类

        和数据表对应的类，一般只包含数据和对数据的基本访问方法(setter,getter)

        一般情况下：一个实体类对应一个表

               一个实体类的对象 对应表中的一行数据

    2》DAO类

        负责对数据库的CRUD（增删改查）

        封装所有对数据库的操作 供其它模块的程序调用

        一帮情况是 一个表对一个DAO类

        DAO 中有很多的方法，每个方法都是对数据库的一种操作

    3》数据连接工具

        用于封装对数据库连接的获取


完整的参考下面（  第一个 ）  后面还有改版.

driver=oracle.jdbc.OracleDriver
url=jdbc:oracle:thin:@c1.zongxuan.online:1521:xx
user=scott
pass=xxxxx
package jdbc;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;

import org.apache.commons.dbcp2.BasicDataSource;

public class DBUtils {
	private static String driver;
	private static String url;
	private static String user;
	private static String pass;
	private static BasicDataSource ds;
	
	static{
		Properties props = new Properties();
		
		try {
			props.load(DBUtils.class.getClassLoader().getResourceAsStream("jdbc/db.properties"));
			driver= props.getProperty("driver");
			url= props.getProperty("url");
			user= props.getProperty("user");
			pass= props.getProperty("pass");
			ds = new BasicDataSource();
			ds.setDriverClassName(driver);
			ds.setUrl(url);
			ds.setUsername(user);
			ds.setPassword(pass);
		} catch (IOException e) {
			e.printStackTrace();
		} 
	}
	
	public static Connection getConnection() throws Exception{
		return ds.getConnection();
	}
	
	public static void main(String[] args) throws Exception{
		Connection con = getConnection();
		System.out.println(con);
	}
	
}
package jdbc;

public class Dept {
	private int deptno;
	private String dname;
	private String loc;
	
	public int getDeptno() {
		return deptno;
	}
	public void setDeptno(int deptno) {
		this.deptno = deptno;
	}
	public String getDname() {
		return dname;
	}
	public void setDname(String dname) {
		this.dname = dname;
	}
	public String getLoc() {
		return loc;
	}
	public void setLoc(String loc) {
		this.loc = loc;
	}

}
package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class DeptDAO {
	private static final String FIND_ALL="select deptno,dname,loc from dept";
	private static final String FIND_BY_LOC="select deptno,dname,loc from dept where loc=?";
	private static final String ADD="insert into dept(deptno,dname,loc) values(?,?,?)";
	public List<Dept> finaALL() throws Exception{
		List<Dept> list;
		Connection con = null;
		try {
			con = DBUtils.getConnection();
			PreparedStatement stmt = con.prepareStatement(FIND_ALL);
			ResultSet rs = stmt.executeQuery();
			list = new ArrayList<Dept>();
			while(rs.next()){
				list.add(toDept(rs));
			}
			return list;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}finally{
			if(con != null){
				con.close();
			}
		}
	}
	
	public List<Dept> findByLoc(String loc) throws Exception{
		List<Dept> list;
		Connection con = null;
		try {
			con = DBUtils.getConnection();
			PreparedStatement stmt = con.prepareStatement(FIND_BY_LOC);
			stmt.setString(1,loc);
			ResultSet rs = stmt.executeQuery();
			list = new ArrayList<Dept>();
			while(rs.next()){
				list.add(toDept(rs));
			}
			return list;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}finally{
			if(con != null){
				con.close();
			}
		}
	}
	
	public void Add(Dept dept) throws Exception{
		Connection con = null;
		try{
			con = DBUtils.getConnection();
			PreparedStatement stmt = con.prepareStatement(ADD);
			stmt.setInt(1, dept.getDeptno());
			stmt.setString(2, dept.getDname());
			stmt.setString(3, dept.getLoc());
			stmt.executeUpdate();
		}catch(Exception e){
			e.printStackTrace();
			throw e;
		}
	}
	
	
	
	private Dept toDept(ResultSet rs) throws SQLException{
		Dept dept = new Dept();
		dept.setDeptno(rs.getInt("deptno"));
		dept.setDname(rs.getString("dname"));
		dept.setLoc(rs.getString("loc"));
		return dept;
	}
	
}
package jdbc;

import java.math.BigDecimal;
import java.sql.Date;

public class Emp {
	//FIND_ALL="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp";
	private int empno;
	private String ename;
	private Date hireDate;
	private BigDecimal sal;
	private String job;
	private int mgr;
	private int comm;
	private int deptno;
	public int getEmpno() {
		return empno;
	}
	public void setEmpno(int empno) {
		this.empno = empno;
	}
	public String getEname() {
		return ename;
	}
	public void setEname(String ename) {
		this.ename = ename;
	}
	public Date getHireDate() {
		return hireDate;
	}
	public void setHireDate(Date hireDate) {
		this.hireDate = hireDate;
	}
	public BigDecimal getSal() {
		return sal;
	}
	public void setSal(BigDecimal sal) {
		this.sal = sal;
	}
	public String getJob() {
		return job;
	}
	public void setJob(String job) {
		this.job = job;
	}
	public int getMgr() {
		return mgr;
	}
	public void setMgr(int mgr) {
		this.mgr = mgr;
	}
	public int getComm() {
		return comm;
	}
	public void setComm(int comm) {
		this.comm = comm;
	}
	public int getDeptno() {
		return deptno;
	}
	public void setDeptno(int deptno) {
		this.deptno = deptno;
	}
	
}
package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class EmpDAO {
	private static final String FIND_ALL="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp";
	private static final String FIND_BY_LOC="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp where ename=?";
	private static final String ADD="insert into emp(empno,ename,job,mgr,hiredate,sal,comm,deptno) values(?,?,?,?,?,?,?,?)";
	public List<Emp> finaALL() throws Exception{
		List<Emp> list;
		Connection con = null;
		try {
			con = DBUtils.getConnection();
			PreparedStatement stmt = con.prepareStatement(FIND_ALL);
			ResultSet rs = stmt.executeQuery();
			list = new ArrayList<Emp>();
			while(rs.next()){
				list.add(toEmp(rs));
			}
			return list;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}finally{
			if(con != null){
				con.close();
			}
		}
	}
	
	public List<Emp> findByLoc(String ename) throws Exception{
		List<Emp> list;
		Connection con = null;
		try {
			con = DBUtils.getConnection();
			PreparedStatement stmt = con.prepareStatement(FIND_BY_LOC);
			stmt.setString(1,ename);
			ResultSet rs = stmt.executeQuery();
			list = new ArrayList<Emp>();
			while(rs.next()){
				list.add(toEmp(rs));
			}
			return list;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}finally{
			if(con != null){
				con.close();
			}
		}
	}
	
	public void Add(Emp emp) throws Exception{
		Connection con = null;
		try{
			con = DBUtils.getConnection();
			PreparedStatement stmt = con.prepareStatement(ADD);
			stmt.setInt(1, emp.getEmpno());
			stmt.setString(2, emp.getEname());
			stmt.setString(3, emp.getJob());
			stmt.setInt(4, emp.getMgr());
			stmt.setDate(5, emp.getHireDate());
			stmt.setBigDecimal(6, emp.getSal());
			stmt.setInt(7, emp.getComm());
			stmt.setInt(8, emp.getDeptno());
			stmt.executeUpdate();
		}catch(Exception e){
			e.printStackTrace();
			throw e;
		}
	}
	
	
	//FIND_ALL="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp";
	private Emp toEmp(ResultSet rs) throws SQLException{
		Emp emp = new Emp();
		emp.setEmpno(rs.getInt("empno"));
		emp.setEname(rs.getString("ename"));
		emp.setJob(rs.getString("job"));
		emp.setMgr(rs.getInt("mgr"));
		emp.setHireDate(rs.getDate("hiredate"));
		emp.setSal(rs.getBigDecimal("sal"));
		emp.setComm(rs.getInt("comm"));
		emp.setDeptno(rs.getInt("deptno"));
		return emp;
	}
}
package jdbc;

import org.junit.Test;

public class TestDeptDAO {

	@Test
	public void testFinadAll() throws Exception{
		for(Dept l:new DeptDAO().finaALL()){
			System.out.println(l.getDeptno()+","+l.getDname()+","+l.getLoc());
		}
	}
	
	@Test
	public void testFinadByLoc() throws Exception{
		for(Dept l:new DeptDAO().findByLoc("DALLAS")){
			System.out.println(l.getDeptno()+","+l.getDname()+","+l.getLoc());
		}
	}
	
	@Test
	public void testAdd() throws Exception{
		Dept dept = new Dept();
		dept.setDeptno(60);
		dept.setDname("RD");
		dept.setLoc("SH");
		new DeptDAO().Add(dept);
	}

}
package jdbc;

import org.junit.Test;



public class TestEmpDAO {
//	private static final String FIND_ALL="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp";
	@Test
	public void test() throws Exception {
		for(Emp l:new EmpDAO().finaALL()){
			System.out.println(l.getEmpno()+","+l.getEname()+","+l.getJob()+","+l.getMgr()+","+l.getHireDate()+","+l.getSal()+","+l.getComm()+","+l.getDeptno());
		}
	}

}








优化一下：

driver=oracle.jdbc.OracleDriver
url=jdbc:oracle:thin:@c1.zongxuan.online:1521:xx
user=scott
pass=xxxxx
package jdbc;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.Properties;

import org.apache.commons.dbcp2.BasicDataSource;

public class DBUtils {
	private static String driver;
	private static String url;
	private static String user;
	private static String pass;
	private static BasicDataSource ds;
	
	static{
		Properties props = new Properties();
		
		try {
			props.load(DBUtils.class.getClassLoader().getResourceAsStream("jdbc/db.properties"));
			driver= props.getProperty("driver");
			url= props.getProperty("url");
			user= props.getProperty("user");
			pass= props.getProperty("pass");
			ds = new BasicDataSource();
			ds.setDriverClassName(driver);
			ds.setUrl(url);
			ds.setUsername(user);
			ds.setPassword(pass);
		} catch (IOException e) {
			e.printStackTrace();
		} 
	}
	
	public static Connection getConnection() throws Exception{
		return ds.getConnection();
	}
	
	public static void main(String[] args) throws Exception{
		Connection con = getConnection();
		System.out.println(con);
	}
	
}
package jdbc;

import java.math.BigDecimal;
import java.sql.Date;

public class Emp {
	//FIND_ALL="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp";
	private int empno;
	private String ename;
	private Date hireDate;
	private BigDecimal sal;
	private String job;
	private int mgr;
	private int comm;
	private int deptno;
	public int getEmpno() {
		return empno;
	}
	public void setEmpno(int empno) {
		this.empno = empno;
	}
	public String getEname() {
		return ename;
	}
	public void setEname(String ename) {
		this.ename = ename;
	}
	public Date getHireDate() {
		return hireDate;
	}
	public void setHireDate(Date hireDate) {
		this.hireDate = hireDate;
	}
	public BigDecimal getSal() {
		return sal;
	}
	public void setSal(BigDecimal sal) {
		this.sal = sal;
	}
	public String getJob() {
		return job;
	}
	public void setJob(String job) {
		this.job = job;
	}
	public int getMgr() {
		return mgr;
	}
	public void setMgr(int mgr) {
		this.mgr = mgr;
	}
	public int getComm() {
		return comm;
	}
	public void setComm(int comm) {
		this.comm = comm;
	}
	public int getDeptno() {
		return deptno;
	}
	public void setDeptno(int deptno) {
		this.deptno = deptno;
	}
	
}
package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

public abstract class BaseDAO {
	//封装查询  修饰符protected
								//sql语句
											//参数
	protected List query(String sql,Object[] o) throws Exception{
		Connection con  = null;
		
		try {
			con = DBUtils.getConnection();
			PreparedStatement stmt = con.prepareStatement(sql);
			if(o != null){
				for(int i =0;i<o.length;i++){
					stmt.setObject(i+1, o[i]);//JDBC 帮你判断具体的参数类型
				}
			}
			ResultSet rs = stmt.executeQuery();
			List list = new ArrayList();
			while(rs.next()){
				list.add(toEntity(rs));
			}
			return list;
		} catch (Exception e) {
			e.printStackTrace();
			throw e;
		}finally{
			if(con != null){
				con.close();
			}
		}
		
	}
	//不同的子类用不通的方法吧结果集中的数据转换
	public abstract Object toEntity(ResultSet rs) throws Exception;
	
}
package jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class EmpDAO extends BaseDAO {
	private static final String FIND_ALL="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp";
	private static final String FIND_BY_ENAME="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp where ename=?";
	private static final String ADD="insert into emp(empno,ename,job,mgr,hiredate,sal,comm,deptno) values(?,?,?,?,?,?,?,?)";
	
	public Object toEntity(ResultSet rs) throws Exception{
		Emp emp = new Emp();
		emp.setEmpno(rs.getInt("empno"));
		emp.setEname(rs.getString("ename"));
		emp.setJob(rs.getString("job"));
		emp.setMgr(rs.getInt("mgr"));
		emp.setHireDate(rs.getDate("hiredate"));
		emp.setSal(rs.getBigDecimal("sal"));
		emp.setComm(rs.getInt("comm"));
		emp.setDeptno(rs.getInt("deptno"));
		return emp;
	}
		
	public List<Emp> finadAll() throws Exception{
		return (List<Emp>)query(FIND_ALL, null);
		
	}
	
	public List<Emp> finadByEname(String ename) throws Exception{
		return (List<Emp>)query(FIND_BY_ENAME,new Object[]{ename});
		
	}

}
package jdbc;

import org.junit.Test;



public class TestEmpDAO {
//	private static final String FIND_ALL="select empno,ename,job,mgr,hiredate,sal,comm,deptno from emp";
	@Test
	public void testFinadAll() throws Exception {
		for(Emp l:new EmpDAO().finadAll()){
			System.out.println(l.getEmpno()+","+l.getEname()+","+l.getJob()+","+l.getMgr()+","+l.getHireDate()+","+l.getSal()+","+l.getComm()+","+l.getDeptno());
		}
	}
	
	
	@Test
	public void testFinaByLoc() throws Exception {
		for(Emp l:new EmpDAO().finadByEname("SCOTT")){
			System.out.println(l.getEmpno()+","+l.getEname()+","+l.getJob()+","+l.getMgr()+","+l.getHireDate()+","+l.getSal()+","+l.getComm()+","+l.getDeptno());
		}
	}
	

}


您可能感兴趣的文档:

--结束END--

本文标题: Java40: 数据库四(Oracle)

本文链接: https://lsjlt.com/news/37466.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • Java40: 数据库四(Oracle)
    JDBC 提供访问数据库的标准  就是一系列接口 定义了访问数据库的通用的方法由各个数据库厂商提供对JDBC的实现JDBC接口的定义数据库厂商对jdbc的实现 jar建立连接-发送sql-执行sq...
    99+
    2024-04-02
  • Oracle 数据库12c新特性总结（四）
    【TechTarget中国原创】本文是Oracle数据库12c新特性的系列文章的第四篇，作者将重点介绍一些对开发者而言非常有用的新特性。相关阅读：Oracle 数据库12c新特性总结（一）、Oracl...
    99+
    2024-04-02
  • 数据库原理四-
    重做日志redo log redo log是重做日志,为InnoDB存储引擎独有。它记录了数据页上的改动。当事务中修改了数据,将会备份存储。 当发生数据库服务器宕机或者脏页未写入磁盘,可以通过redo log恢复。 redo log用于配...
    99+
    2022-02-09
    数据库原理四-
  • oracle系列（四）oracle事务和常用数据库对象
    博主QQ：819594300博客地址：http://zpf666.blog.51cto.com/有什么疑问的朋友可以联系博主，博主会帮你们解答，谢谢支持！前言：本次内容的相关知识点我们在学习sqlserve...
    99+
    2024-04-02
  • MySQL数据库(四)数据库和表操作
    4.1 连接 在最初安装MySQL，可能会要求你输入一个管理登录（通常为root）和一个口令（密码）。 连接MySQL需要以下信息： 主机名（计算机名）——如果连接到本地MySQL服务器，为localhost； 端口（如果使用默...
    99+
    2018-05-11
    MySQL数据库(四)数据库和表操作
  • Oracle连接远程数据库的四种方法
    Oracle数据库的远程连接可以通过多种方式来实现，本文我们主要介绍四种远程连接的方法和注意事项，并通过示例来说明，接下来我们就开始介绍 第一种方法： 若oracle服务器装在本机上，那就不多说了，连接...
    99+
    2024-04-02
  • 数据库学习之四：数据库用户管理
    四、数据库用户管理 1、用户定义 用户定义： mysql> select user,host,password from mysql.user; +------+--------------+--------------...
    99+
    2022-01-11
    数据库学习之四：数据库用户管理
  • MySQL数据库知识汇总（四）
    ...
    99+
    2024-04-02
  • mysql 8.0 四个默认数据库
    mysql 8.0 安装完成后会自动生成四个数据库information_schemaNFORMATION_SCHEMA提供对数据库元数据的访问 ，有关MySQL服务器的信息，例如数据库或表的名称，列的数据...
    99+
    2024-04-02
  • MYSQL数据库学习系列四
    MYSQL数据库学习系列四 四．MYSQL的应用优化4.1-MySQL索引优化与设计什么是索引索引的意义 —— 快速定位要查找的数据数据库索引查找全表扫描 VS 索引...
    99+
    2024-04-02
  • 数据库安装四种方法
      安装数据库 一、在网上下载安装包 wget https://cdn.mysql.com//Downloads/MySQL-8.0/mysql-8.0.30-1.el8.x86_64.rpm-bundle.tar 解压 tar xvf ...
    99+
    2023-09-01
    数据库 mysql 服务器
  • 【数据库】Oracle -
    码农的成长     首页     新随笔    新文章             管理 ...
    99+
    2015-06-06
    【数据库】Oracle -
  • 数据库——oracle
    为什么要用数据库？ 文件存储： 1、不易于管理和分析（Linux操作系统下输入ls命令会卡死） 2、不易于共享 3、文件内容不断增大，不易于存储 数据库：用数据结构来管理、存储数据的仓库 DB：Databa...
    99+
    2024-04-02
  • oracle数据库
    用户（user）是定义在数据库中的一个名称，访问数据库时，要提供合适的用户名和口令。模式（Schema）是用户所拥有对象的集合。用户与模式是一一对应的关系，并且二者名称相同。在Oracle 数据库中建立用户...
    99+
    2024-04-02
  • Redis-nosql数据库的四大分类
                         Redis-nosql数据库的四大分类原文地址：https://www.cnblogs.com/ibcdwx/p/13472428.html...
    99+
    2016-07-04
    Redis-nosql数据库的四大分类 数据库入门 数据库基础教程 数据库 mysql
  • mysql数据库limit的四种用法
    文章目录 前言一、语法二、参数说明三、常用示例-4种用法总结 前言 mysql数据库中limit子句可以被用于强制select语句返回指定的记录数。limit接受一个或两个数字...
    99+
    2023-10-20
    数据库 mysql
  • Flask入门到放弃（四）—— 数据库
    转载请在文章开头附上原文链接地址：https://www.cnblogs.com/Sunzz/p/10979970.html ORM ORM 全拼Object-Relation Mapping，中文意为 对象-关系映射。主要实现模型对象...
    99+
    2023-01-31
    入门 数据库 Flask
  • 【数据库的四种隔离级别】
    在关系型数据库中，隔离级别是指多个事务并发执行时，彼此之间的隔离程度。数据库的四种隔离级别如下： 1.读未提交（Read Uncommitted）： 最低级别的隔离级别，一个事务可以读取到另一个事务未提交的数据，可能会出现脏读、不可重复读和...
    99+
    2023-08-19
    数据库 java 开发语言
  • Oracle 数据库启动过程的三阶段、停库四种模式详解
    目录数据库的启动过程（3个台阶）1.nomount2.mount3.open数据库的启动过程（3个台阶） 1.nomount shutdown --> nomount startup nomount selec&#...
    99+
    2022-11-21
    Oracle 数据库启动 Oracle 数据库停库
  • 【数据库_06】Oracle
    二、数据库操作 1. 创建表空间 CREATE TABLESPACE "FIRSTDEMO" DATAFILE  "C:/oracle/firstdemo"  SIZE 100M  AUTOEXTEND ON  NEXT 10M 2. 创...
    99+
    2017-03-10
    【数据库_06】Oracle
软考高级职称资格查询
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作