ICode9

精准搜索请尝试: 精确搜索
首页 > 数据库> 文章详细

Java操作Oracle并实现增删改查

2022-02-25 10:03:46  阅读:176  来源: 互联网

标签:ps Java String 改查 connection SQLException sql Oracle public


由于Oracle授权问题,Maven3不提供Oracle JDBC driver,需要手动添加 (具体方法在上面的随笔中有详细说明)

直接上代码

OracleUtil 连接类

package com.JavaOracle;

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

public class OracleUtil {
    //数据库连接地址
    private static String url="jdbc:oracle:thin:@192.168.1.180:1521:orcl";
    //用户名
    private static String username= "sys as sysdba";
    //密码
    private static String password ="admindljjk";
    //驱动名称
    private static String jdbcName = "oracle.jdbc.OracleDriver";

    /*获取数据库连接 */
    public static Connection getCon(){
        try {
            Class.forName(jdbcName);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        Connection con = null;
        try {
            con = DriverManager.getConnection(url,username,password);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return con;
    }

    /*关闭数据库连接*/
    public static void closeCon(Connection con) throws SQLException {
        if (con != null)
            con.close();
    }

    /*
    public static void main(String[] args){
        try {
            getCon();
            System.out.println("数据库连接成功");
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("数据库连接失败");
        }
    }
    */

}

OracleDemo   具体业务增删改查类

package com.JavaOracle;

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

public class OracleDemo {

    //连接对象
    Connection connection=null;
    //创建预编译对象
    PreparedStatement ps=null;
    //创建结果集
    ResultSet rs = null;

    /*插入*/
    public int insert(){
        int result = 0;
        connection = OracleUtil.getCon();
        String sql = "insert into CTI_AGENT_WORK_REST ";
        sql=sql+" (ID,AGENT_NAME,DATE_TIME,STATUS) ";
        sql=sql+" values(?,?,?,? )";
        try {
            ps = connection.prepareStatement(sql);
            ps.setInt(1,2323232);
            ps.setString(2,"老刘");
            ps.setString(3,"2021-07-26 15:51:12");
            ps.setString(4,"Rest");

            result = ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            try {
                OracleUtil.closeCon(connection);
            }catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return result;
    }
    /*查询*/
    public void select(){
        connection = OracleUtil.getCon();
        String sql = "select * from CTI_AGENT_WORK_REST";
        try {
            ps = connection.prepareStatement(sql);
            rs = ps.executeQuery();
            while (rs.next()){
                int id = rs.getInt(1);
                String AGENT_NAME = rs.getString(2);
                String DATE_TIME = rs.getString(3);
                String STATUS= rs.getString(4);
                System.out.println("ID:"+id + " AGENT_NAME:"+AGENT_NAME+" DATE_TIME:"+DATE_TIME+" STATUS:"+STATUS);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            try {
                OracleUtil.closeCon(connection);
            }catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    /*修改*/
    public int update(){
        connection = OracleUtil.getCon();
        String sql = "update student set name = ?,gender = ? where id = ?";
        int result = 0;
        try {
            ps = connection.prepareStatement(sql);
            ps.setString(1,"老张");
            ps.setString(2,"男");
            ps.setInt(3,2);
            result = ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            try {
                OracleUtil.closeCon(connection);
            }catch (SQLException e) {
                e.printStackTrace();
            }
        }

        return result;

    }

    /*删除 */
    public int delete(){
        int result = 0;
        connection = OracleUtil.getCon();
        String sql = "delete from student where id = ?";
        try {
            ps = connection.prepareStatement(sql);
            ps.setInt(1,1);
            result = ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            try {
                OracleUtil.closeCon(connection);
            }catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return result;
    }

    /*
    public static void main(String[] args){
        OracleDemo od = new OracleDemo();
        //int add = od.add();
        System.out.println(add);
        od.select();
//        System.out.println(od.delete());
    }*/

}
主函数
public static void main( String[] args )
 {
        System.out.println( "Hello JavaOracle !" );

        OracleDemo myDB = new OracleDemo();
        int result = myDB.insert();
        System.out.println("insert 结果: "+result);
        myDB.select();
        //System.out.println(myDB.delete());
 }

 


标签:ps,Java,String,改查,connection,SQLException,sql,Oracle,public
来源: https://www.cnblogs.com/hailexuexi/p/15062306.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有