JAVA-JDBC连接增编削查

 起首与oracle创建连接

1. package com.ma;
3. import com.sun.media.sound.SoftTuning;
5. import java.sql.*;
7. public class JDBCtest {
8.     public static void main(String[] args) throws Exception {
9.         //1.加载驱动
10.         Class.forName("oracle.jdbc.driver.OracleDriver");
11.         //2.建立连接
12.         Connection connection = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl", "scott", "123456");
13.         //3.测试建立连接
14.         System.out.println(connection);
15.         //4.定义sql语句
16.         String sql ="select * from emp";
17.         //5.准备静态处理块对象,将sql语句放置到静态代码块中
18.         Statement statement=connection.createStatement();
19.         //6.执行sql语句,返回值对象是结果集合
20.         ResultSet resultSet = statement.executeQuery(sql);
21.         //7.循环处理
22.         while (resultSet.next()){
23.             int anInt = resultSet.getInt(1);
24.             System.out.println(anInt);
25.             String ename = resultSet.getString("ename");
26.             System.out.println(ename);
28.             System.out.println("----------------");
30.         }
31.         //8.关闭连接
32.         statement.close();
33.         connection.close();
34.     }
35. }

复制代码

 测试连接

1. package com.ma;
3. import java.sql.Connection;
4. import java.sql.DriverManager;
5. import java.sql.Statement;
6. import java.util.function.Consumer;
8. public class CreateTable {
9.     public static void main(String[] args) throws Exception {
10.         Class.forName("oracle.jdbc.driver.OracleDriver");
11.         Connection connection = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl", "scott", "123456");
12.         Statement statement = connection.createStatement();
13.         String sql="create table psn(id number(10) primary key,name varchar2(10))";
14.         boolean execute = statement.execute(sql);
15.         System.out.println(execute);
16.         statement.close();
17.         connection.close();
20.     }
21. }

复制代码

减少代码冗余性,创建代码块

1. package com.ma.util;
4. import java.sql.*;
6. public class DBUtil {
7.     public static final  String URL="jdbc:oracle:thin:@localhost:1521:orcl";
8.     public static final  String USENAME="scott";
9.     public static final  String PASSWORE="123456";
11.     static {
12.         try {
13.             Class.forName("oracle.jdbc.driver.OracleDriver");
14.         } catch (ClassNotFoundException e) {
15.             throw new RuntimeException(e);
16.         }
17.     }
18.     public static Connection getConnection(){
19.         try {
20.             return DriverManager.getConnection(URL,USENAME,PASSWORE);
21.         } catch (SQLException e) {
22.             throw new RuntimeException(e);
23.         }
25.     }
26.     public static  void closeConnection(Connection connection, Statement statement) {
27.        if(statement!=null){
28.            try {
29.                statement.close();
30.            } catch (SQLException e) {
31.                throw new RuntimeException(e);
32.            }
33.        }
34.         if (connection != null) {
35.             try {
36.                 connection.close();
37.             } catch (SQLException e) {
38.                 throw new RuntimeException(e);
39.             }
40.         }
41.     }
46.     public static void closeConnection(Connection connection, Statement statement, ResultSet resultSet) {
47.        if(resultSet!=null){
48.            try {
49.                resultSet.close();
50.            } catch (SQLException e) {
51.                throw new RuntimeException(e);
52.            }
53.        }
54.         if(statement!=null){
55.             try {
56.                 statement.close();
57.             } catch (SQLException e) {
58.                 throw new RuntimeException(e);
59.             }
60.         }
61.         if (connection != null) {
62.             try {
63.                 connection.close();
64.             } catch (SQLException e) {
65.                 throw new RuntimeException(e);
66.             }
67.         }
68.     }
70. }

复制代码

下面创建增编削查

1. package com.ma.dao;
3. import com.ma.entity.Emp;
5. public interface EmpDao {
6.     public void insert(Emp emp);
7.     public void delete(Emp emp);
8.     public void update(Emp emp);
9.     public Emp getEmpByEmpno(Integer empno);
11. }

复制代码

1. package com.ma.dao.impl;
3. import com.ma.dao.EmpDao;
4. import com.ma.entity.Emp;
5. import com.ma.util.DBUtil;
7. import java.security.PublicKey;
8. import java.sql.Connection;
9. import java.sql.Date;
10. import java.sql.SQLException;
11. import java.sql.Statement;
13. public class EmpDaolmpl implements EmpDao {
14.     @Override
15.     public void insert(Emp emp) {
16.         Connection connection=null;
17.         Statement statement=null;
18.         try {
19.             connection= DBUtil.getConnection();
20.             statement=connection.createStatement();
21.             String sql="insert into emp values("+emp.getEmpno()+",'"+emp.getEname()+"','"+emp.getJob()+"'," +
22.                     ""+emp.getMrg()+",to_date('"+emp.getHiredate()+"','YYYY-MM-DD'),"+emp.getSal()+"," +
23.                     ""+emp.getComm()+","+emp.getDeptno()+")";
24.             System.out.println(sql);
25.             int i = statement.executeUpdate(sql);
26.             System.out.println("受影响的行数是:"+i);
27.         } catch (SQLException e) {
28.             throw new RuntimeException(e);
29.         }finally {
30.             DBUtil.closeConnection(connection,statement);
31.         }
32.     }
34.     @Override
35.     public void delete(Emp emp) {
36.         Connection connection=null;
37.         Statement statement=null;
38.         try {
39.             connection= DBUtil.getConnection();
40.             statement=connection.createStatement();
41.             String sql="delete from emp where empno="+emp.getEmpno();
42.             System.out.println(sql);
43.             int i = statement.executeUpdate(sql);
44.             System.out.println("受影响的行数是:"+i);
45.         } catch (SQLException e) {
46.             throw new RuntimeException(e);
47.         }finally {
48.             DBUtil.closeConnection(connection,statement);
49.         }
50.     }
52.     @Override
53.     public void update(Emp emp) {
54.         Connection connection=null;
55.         Statement statement=null;
56.         try {
57.             connection= DBUtil.getConnection();
58.             statement=connection.createStatement();
59.             String sql="update emp set job='"+emp.getJob()+"'where empno ="+emp.getEmpno();
60.             System.out.println(sql);
61.             int i = statement.executeUpdate(sql);
62.             System.out.println("受影响的行数是:"+i);
63.         } catch (SQLException e) {
64.             throw new RuntimeException(e);
65.         }finally {
66.             DBUtil.closeConnection(connection,statement);
67.         }
68.     }
70.     @Override
71.     public Emp getEmpByEmpno(Integer empno) {
72.         return null;
73.     }
75.     public static void main(String[] args) {
76.         EmpDao empDao=new EmpDaolmpl();
77.         Emp emp=new Emp(222,"sisi","SALES",1111,"2025-2-18",1500.0,500.0,10);
78. //        empDao.insert(emp);
79. //        empDao.delete(emp);
80.         empDao.update(emp);
81.     }
83. }

复制代码

1. package com.ma.entity;
3. import java.util.Date;
5. public class Emp {
6.     private Integer empno;
7.     private String ename;
8.     private String job;
9.     private Integer mrg;
10.     private String hiredate;
11.     private Double sal;
12.     private Double comm;
13.     private  Integer deptno;
14.     public  Emp(){
16.     }
18.     public Emp(Integer empno, String ename, String job, Integer mrg, String hiredate, Double sal, Double comm, Integer deptno) {
19.         this.empno = empno;
20.         this.ename = ename;
21.         this.job = job;
22.         this.mrg = mrg;
23.         this.hiredate = hiredate;
24.         this.sal = sal;
25.         this.comm = comm;
26.         this.deptno = deptno;
27.     }
29.     public Integer getEmpno() {
30.         return empno;
31.     }
33.     public void setEmpno(Integer empno) {
34.         this.empno = empno;
35.     }
37.     public String getEname() {
38.         return ename;
39.     }
41.     public void setEname(String ename) {
42.         this.ename = ename;
43.     }
45.     public String getJob() {
46.         return job;
47.     }
49.     public void setJob(String job) {
50.         this.job = job;
51.     }
53.     public Integer getMrg() {
54.         return mrg;
55.     }
57.     public void setMrg(Integer mrg) {
58.         this.mrg = mrg;
59.     }
61.     public String getHiredate() {
62.         return hiredate;
63.     }
65.     public void setHiredate(String hiredate) {
66.         this.hiredate = hiredate;
67.     }
69.     public Double getSal() {
70.         return sal;
71.     }
73.     public void setSal(Double sal) {
74.         this.sal = sal;
75.     }
77.     public Double getComm() {
78.         return comm;
79.     }
81.     public void setComm(Double comm) {
82.         this.comm = comm;
83.     }
85.     public Integer getDeptno() {
86.         return deptno;
87.     }
89.     public void setDeptno(Integer deptno) {
90.         this.deptno = deptno;
91.     }
93.     @Override
94.     public String toString() {
95.         return "Emp{" +
96.                 "empno=" + empno +
97.                 ", ename='" + ename + '\'' +
98.                 ", job='" + job + '\'' +
99.                 ", mrg=" + mrg +
100.                 ", hiredate=" + hiredate +
101.                 ", sal=" + sal +
102.                 ", comm=" + comm +
103.                 ", deptno=" + deptno +
104.                 '}';
105.     }
106. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。