java 連接oracle 進行增刪改查


1、在DAO層新增類OraclePersionDao

package com.test.dao;

import java.sql.*;

/**
 * Created by wdw on 2017/9/16.
 */
public class OraclePersionDao {

    // 數據庫驅動類
    private String dbDriver = "oracle.jdbc.driver.OracleDriver";
    // 連接數據庫url
    private String dbURL = "jdbc:oracle:thin:@192.168.31.128:1521:orcl";
    // 連接數據庫用戶名
    private String dbUser = "PHIP";
    // 連接數據庫密碼
    private String dbPwd = "PHIP";
    // 獲取數據庫連接方法, 返回Connection對象
    private Connection con = null;
    //數據執行語句
    private Statement stat = null;
    private String sql = null;
    private ResultSet rs = null;

    //創建數據庫連接
    public Connection getDBConnect() {
        try {
// 加載數據庫驅動
            Class.forName(dbDriver);
            con = DriverManager.getConnection(dbURL, dbUser, dbPwd);
        } catch (Exception e) {
            System.out.println(e);
        }
        return con;
    }

    //增加
    public void Add() {
        con = getDBConnect();
        sql = "insert into sys_users(id,code,name)" +
                "values('1','lucy','w')";
        try {
            stat = con.createStatement();
            stat.executeUpdate(sql);
        }
        catch (SQLException e) {
// TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    //刪除
    public void Delete() {
        con = getDBConnect();
        sql = "delete  from sys_users " +
                "where ID=1";
        try {
            stat = con.createStatement();
            stat.executeUpdate(sql);
        } catch (SQLException e) {
// TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

    //修改
    public void Update() {
        con = getDBConnect();
        sql = "update sys_users set code='c2' where id='1'";
        try {
            stat = con.createStatement();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    //查詢
    public void Search() {
        con = getDBConnect();
// 創建表的sql語句
        sql = "SELECT * FROM sys_users";
        try {
            stat = con.createStatement();
            rs = stat.executeQuery(sql);
            while (rs.next()) {
                String id = rs.getString(1);
                String stuname = rs.getString(2);
                String stusex = rs.getString(3);
                System.out.println(id + "," + stuname + "," + stusex);
            }
        } catch (SQLException e) {
// TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
//功能:關閉數據庫的連接

    public void close() {//6.釋放資源
        try { // 捕捉異常
            try {
                if (rs != null) { // 當ResultSet對象的實例rs不為空時

                    rs.close(); // 關閉ResultSet對象
                }
            } finally {
                try {
                    if (stat != null) { // 當Statement對象的實例stmt不為空時

                        stat.close(); // 關閉Statement對象
                    }
                } finally {
                    if (con != null) { // 當Connection對象的實例conn不為空時
                        con.close(); // 關閉Connection對象
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace(System.err); // 輸出異常信息
        }
    }

}
View Code

2、main

 private static void MySqlOperator() {
           
        OraclePersionDao oracl = new OraclePersionDao();

        oracl.Add();
        oracl.Search();
        oracl.Update();
        oracl.Delete();

    }
View Code

3、增加oracle驅動到本項目

找到安裝oracle的目錄x:\oracle\product\10.2.0\db_1\jdbc\lib\ojdbc14.jar  (注,不同版本會有不同名稱)

復制該文件,點擊WEB-INFO,Ctrl+v粘貼文件,點OKOKOK

右鍵粘貼的文件,Add  as library 一直點OK。,

3、測試

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM