使用IDEA对Oracle数据库进行简单增删改查操作

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.Statement;

import java.util.Scanner;

//与数据库建立连接

public class ConnectionTest {

   //获取连接的三个基本信息

   private String dbURL = "jdbc:oracle:thin:@localhost:1521:orcl" ;

   private String dbUser = "test" ;

   private String dbPwd = "test" ;

   // 获取数据库连接方法, 返回Connection对象

   private Connection con = null ;

   //创建数据库连接

   public Connection getDBConnect() {

     try {

       // 加载数据库驱动 不同的数据库下面这个驱动是不同的，这个千万要注意!!!

       Class.forName( "oracle.jdbc.driver.OracleDriver" );

       con = DriverManager.getConnection(dbURL, dbUser, dbPwd);

     } catch (Exception e) {

       System.out.println(e);

     }

     return con;

   }

}

public void testInsert() {

       PreparedStatement ps1 = null ; //使用该类执行增删改操作不会发生sql注入现象！！

     //在进行插入操作的时候 保证你的表、以及对应的列名都存在 ？在这里表示占位符

     String sql = "insert into t_user(ID,USERNAME,PASSWORD1,EMAIL) values(?,?,?,?)" ;

     try {

      //1、预编译sql语句 返回PreparedStatement的实例给ps1 con表示Connection的对象

       ps1 = con.prepareStatement(sql);

       //2、填充占位符=？

       ps1.setString( 1 , "2" );

       ps1.setString( 2 , "ww" );

       ps1.setString( 3 , "12345" );

       ps1.setString( 4 , "907372669@qq.com" );

       //执行操作

       ps1.execute();

     } catch (SQLException e) {

       e.printStackTrace();

     }

     //资源的关闭

     try {

       if (ps1 != null )

         ps1.close();

     } catch (SQLException e) {

       e.printStackTrace();

     }

     try {

       if (con != null )

         con.close();

     } catch (SQLException e) {

       e.printStackTrace();

     }

   }

public void testUpdate() {

     PreparedStatement ps2 = null ;

     //编写sql语句 返回PreparedStatement的实例

     String sql = "update T_USER set USERNAME = ? where ID = ? " ;

     try {

       ps2 = con.prepareStatement(sql);

        //填充占位符=？

       ps2.setObject( 1 , "newgg" );

       ps2.setObject( 2 , "1" );

       //执行

       ps2.execute();

     } catch (SQLException e) {

       e.printStackTrace();

     }

     //实现资源关闭的方法

     closeSources(ps2,con);

   }

   //实现资源关闭的方法如下:

public void closeSources(PreparedStatement ps, Connection con) {

     try {

       if (ps != null )

         ps.close();

     } catch (SQLException e) {

       e.printStackTrace();

     }

     try {

       if (con != null )

         con.close();

     } catch (SQLException e) {

       e.printStackTrace();

     }

}

public void testUpdate() {

  //编写sql语句 返回PreparedStatement的实例

     PreparedStatement ps2 = null ;

     String sql = "update T_USER set USERNAME = ? where ID = ? " ;

     try {

       ps2 = con.prepareStatement(sql);

       //填充占位符=?

       ps2.setObject( 1 , "newgg" );

       ps2.setObject( 2 , "1" );

       //执行

       ps2.execute();

     } catch (SQLException e) {

       e.printStackTrace();

     }

     //实现资源的关闭

     closeSources(ps2,con);

   }

//实现增删改的通用操作

// sql占位符中的个数与可变长参数的长度一致！！

   public void insert_Delete_Update(String sql, Object ...args) {

    //预编译SQL语句，返回PreparedStatement的实例

     PreparedStatement ps4 = null ;

     try {

       ps4 = con.prepareStatement(sql);

       //填充占位符

       for ( int i= 0 ; i<args.length; i++) {

         ps4.setObject(i+ 1 ,args[i]);

       }

       //执行

       ps4.execute();

     } catch (SQLException e) {

       e.printStackTrace();

     }

     //实现资源的关闭

     closeSources(ps4,con);

   }

public void test_Insert_Delete_Update() {

    String sql1 = "update T_USER set username = ? where ID = ? " ;

    //仔细观察这个调用的方法 username=[newQ] ID=[2]这两个参数传入这个方法里

    insert_Delete_Update(sql1, "newQ" , "2" );

  }