AI 助理
文档备案控制台
开发者社区 数据库 文章 正文

java学习：数据增删改查、存储过程调用及事务处理

2012-11-16 1188
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 为了方便，先定义二个常量: package jmyang.utils; public class ConstDefine { /** * WebLogic服务器地址 */ public static final String WebLogi...

为了方便，先定义二个常量:

package jmyang.utils;

public class ConstDefine {

    /**
     * WebLogic服务器地址
     */
    public static final String WebLogicServerUrl = "t3://localhost:7001";

    /**
     * WebLogic JNDI上下文字符串
     */
    public static final String WebLogicINDIContextFactory = "weblogic.jndi.WLInitialContextFactory";


}

 并把创建连接，关闭连接等基本方法 封装一下：

package jmyang.utils;

import javax.naming.Context;
import java.util.Hashtable;
import javax.naming.InitialContext;
import jmyang.utils.ConstDefine;
import javax.naming.NamingException;
import java.sql.Connection;
import javax.sql.DataSource;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.ResultSet;

/**
 *
 * <p>Title: JDBC工具类</p>
 * <p>Description: 封装JDBC常用的基本操作</p>
 * <p>Copyright: Copyright (c) 2012</p>
 * <p>Company: yjmyzz.cnblogs.com</p>
 * @author: yjmyzz@126.com
 * @version 1.0
 */
public class JDBC {

    private static Context ctx = null;

    /**
     * 获取weblogic上下文
     * @return Context
     */
    public static Context getContext() {
        Hashtable ht = new Hashtable();
        ht.put(Context.INITIAL_CONTEXT_FACTORY,
               ConstDefine.WebLogicINDIContextFactory);
        ht.put(Context.PROVIDER_URL, ConstDefine.WebLogicServerUrl);
        try {
            ctx = new InitialContext(ht);
        } catch (NamingException e) {
            e.printStackTrace();
            return null;
        }
        return ctx;
    }

    /**
     * 获取DataSource
     * @param dsName String
     * @return DataSource
     */
    public static DataSource getDataSource(String dsName) {
        if (ctx == null) {
            ctx = getContext();
        }
        if (ctx == null || dsName == null) {
            return null;
        }
        DataSource ds = null;
        try {
            ds = (javax.sql.DataSource) ctx.lookup(dsName);
        } catch (NamingException e) {
            e.printStackTrace();
            return null;
        }
        return ds;
    }

    /**
     * 获取连接对象
     * @return Connection
     */
    public static Connection getConnection(DataSource ds) {
        if (ds == null) {
            return null;
        }
        Connection conn = null;
        try {
            conn = ds.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
            return null;
        }
        return conn;
    }

    /**
     * 获取连接对象
     * @param dsName String
     * @param autoCommitTransaction boolean 是否自动提交事务
     * @return Connection
     */
    public static Connection getConnection(String dsName,
                                           boolean autoCommitTransaction) {
        if (dsName == null) {
            return null;
        }
        DataSource ds = getDataSource(dsName);
        if (ds == null) {
            return null;
        }
        Connection conn = null;
        try {
            conn = ds.getConnection();
            conn.setAutoCommit(autoCommitTransaction);
        } catch (SQLException e) {
            e.printStackTrace();
            return null;
        }
        return conn;
    }

    /**
     * 获取连接对象(自动提交事务)
     * @param dsName String
     * @return Connection
     */
    public static Connection getConnection(String dsName) {
        return getConnection(dsName, true);
    }


    /**
     * 关闭连接
     * @param conn Connection
     * @param autoCommitTransaction boolean 是否自动提交事务
     */
    public static void closeConnection(Connection conn,
                                       boolean autoCommitTransaction) {
        if (conn != null) {
            if (autoCommitTransaction) {
                //如果自动提交事务
                try {
                    conn.commit();
                } catch (SQLException e) {
                    e.printStackTrace();
                    try {
                        conn.rollback();
                    } catch (SQLException e2) {
                        e2.printStackTrace();
                    }
                }
            } else {
                //否则回滚
                try {
                    conn.rollback();
                } catch (SQLException e2) {
                    e2.printStackTrace();
                }

            }
            //关闭连接
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }

        }
    }

    /**
     * 关闭数据连接(并自动提交事务)
     * @param conn Connection
     */
    public static void closeConnection(Connection conn) {
        closeConnection(conn, true);
    }

    /**
     * 关闭查询
     * @param statement Statement
     */
    public static void closeStatement(Statement statement) {
        if (statement != null) {
            try {
                statement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

    }

    /**
     * 执行sql查询
     * @param dsName string
     * @param sql string
     * @return ResultSet
     */
    public static ResultSet executeQuery(String dsName, String sql) {
        Connection conn = getConnection(dsName);
        if (conn == null) {
            System.out.println("数据库连接失败！");
            return null;
        }
        ResultSet resultSet = null;
        Statement cmd = null;
        try {
            cmd = conn.createStatement();
            resultSet = cmd.executeQuery(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            closeStatement(cmd);
            closeConnection(conn);
        }
        return resultSet;
    }

    /**
     * 执行sql更新/插入/删除
     * @param dsName String
     * @param sql String
     * @return 影响的行数
     */
    public static int executeUpdate(String dsName, String sql) {
        int result = 0;
        Connection conn = JDBC.getConnection(dsName);
        Statement cmd = null;
        try {
            cmd = conn.createStatement();
            result = cmd.executeUpdate(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBC.closeStatement(cmd);
            JDBC.closeConnection(conn);
        }
        return result;
    }


    /**
     * 执行sql语句(注：并不自动关闭连接，需要在开发人员调用完成后，手动关闭conn对象)
     * @param conn Connection
     * @param sql String
     * @return int
     */
    public static int executeUpdate(Connection conn, String sql) {
        int result = 0;
        Statement cmd = null;
        try {
            cmd = conn.createStatement();
            result = cmd.executeUpdate(sql);
        } catch (SQLException e) {
            e.printStackTrace();
            try {
                conn.rollback();//如果失败，尝试回滚
            } catch (SQLException e2) {
                e2.printStackTrace();
            }
        } finally {
            JDBC.closeStatement(cmd);
        }
        return result;
    }

}

 下面的代码，演示了基础的增、删、改、查以及事务的使用

package jmyang.jndi;



import jmyang.utils.*;
import javax.sql.*;
import java.sql.*;


public class JDBCTest {

    static final String WeblogicDataSoueceName = "oracleXE";
    /**
     * 查询示例
     */
    public static void QueryDemo() {
    
        
        ResultSet resultSet = JDBC.executeQuery(WeblogicDataSoueceName,
                                                "Select * from EMP");
        try {
            while (resultSet.next()) {
                System.out.println("EMPNO=" + resultSet.getString("EMPNO") + ",ENAME=" + resultSet.getString("ENAME"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 新增记录示例
     */
    public static void InsertDemo() {
        if (JDBC.executeUpdate(WeblogicDataSoueceName,
                               "INSERT INTO DEPT VALUES('50','市场部','上海')") > 0) {
            System.out.println("insert 记录成功！");
        } else {
            System.out.println("insert 记录失败！");
        }
    }

    /**
     * 删除示例
     */
    public static void DeleteDemo() {
        if (JDBC.executeUpdate(WeblogicDataSoueceName,
                               "Delete From Dept Where DeptNo='50'") > 0) {
            System.out.println("delete 记录成功！");
        } else {
            System.out.println("delete 记录失败！");
        }
    }

    /**
     * 更新示例
     */
    public static void UpdateDemo() {
        if (JDBC.executeUpdate(WeblogicDataSoueceName,
                               "Update Dept Set LOC='中国上海' Where DeptNo='50'") >
            0) {
            System.out.println("update 记录成功！");
        } else {
            System.out.println("update 记录失败！");
        }
    }

    /**
     * 简单事务示例
     */
    public static void transactionDemo() {
        Connection conn = JDBC.getConnection(WeblogicDataSoueceName, false);//设置不自动提交事务
        try {
            JDBC.executeUpdate(conn, "INSERT INTO DEPT VALUES('50','市场部','上海')");
            JDBC.executeUpdate(conn, "INSERT INTO DEPT VALUES('60','技术部')"); //这里故意少写一个字段的值，insert时失败,导致事务回滚
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            JDBC.closeConnection(conn);
        }
    }

}

从上面的代码可以看出：对于日常的数据库操作，用Statement对象的executeQuery(),executeUpate()以及Connection.setAutoCommit()基本上就满足增、删、改、查需求，以及事务的调用

下面来看看存储过程的调用：

先在oracle中创建一个示例存储过程

create or replace procedure up_getENameByNo(empno in varchar2,
                                            eName out varchar2) is

begin
  select t.ename
    into eName
    from emp t
   where empno = empno
     and rownum = 1;
  
end up_getENameByNo;

 很简单，根据empno获取emp表中的ename字段值，下面是java的调用代码：

    /**
     * 存储过程调用示例
     */
    public static void procedureDemo(){
        Connection conn = JDBC.getConnection(WeblogicDataSoueceName);
        try{
           CallableStatement statement= conn.prepareCall("{call up_getENameByNo(?,?)}");
           statement.setString(1,"7839");//设置第一个参数值为7839
           statement.registerOutParameter(2,Types.VARCHAR);//注册第二个参数为返回参数
           statement.execute();           
           System.out.println(statement.getString(2));//显示返回参数
        }
        catch(SQLException e){
            e.printStackTrace();
        }
        finally{
            JDBC.closeConnection(conn);
        }
    }

 这里我们又用到了一个新对象：CallableStatement，存储过程的调用就是通过它来完成的。

最后再来看看SQL注入及参数化问题，众所周知，用SQL拼接的方式处理查询参数，默认情况下有安全问题，下面的代码演示了这一点：

    public static void queryDemo() {
        String deptNo = "'30' or 1=1";
        ResultSet resultSet = JDBC.executeQuery(WeblogicDataSoueceName,
                                                "Select * from EMP where deptno=" + deptNo + " order by ename desc");
        String empNo, eName;
        try {
            while (resultSet.next()) {
                empNo = resultSet.getString("EMPNO");
                eName = resultSet.getString("eName");
                deptNo = resultSet.getString("DeptNo");
                System.out.println("EMPNO=" + empNo + " ， ENAME=" + eName + " ， DEPTNO=" + deptNo);               
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

 代码本意是要查出DeptNo=30的记录，但是最终却查出了所有记录！(特别是该查询参数值是从前端界面上客户输入时，这个问题显得很严重了)。当然java也有相应的策略：那就是尽量使用PreparedStatement，以参数化的方式处理，下面是示例代码：

/**
     * 查询示例（使用PreparedStatement）
     */
    public static void queryDemoP() {

        Connection conn = null;
        PreparedStatement statement = null;
        String empNo, eName,deptNo;
        try {
            conn = JDBC.getConnection(WeblogicDataSoueceName);
            statement = conn.prepareStatement(
                    "select * from emp where deptno=? order by ename desc");//注意这里的?号
            statement.setString(1, "'30' or 1=1");//设置第一个参数的值

            ResultSet resultSet = statement.executeQuery();

            while (resultSet.next()) {
                empNo = resultSet.getString("EMPNO");
                eName = resultSet.getString("eName");
                deptNo = resultSet.getString("DeptNo");
                System.out.println("EMPNO=" + empNo + " ， ENAME=" + eName + " ， DEPTNO=" + deptNo);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBC.closeStatement(statement);
            JDBC.closeConnection(conn);
        }
    }

运行时会报错：

java.sql.SQLException: ORA-01722: 无效数字

显然，statement.setString(1, "'30' or 1=1");的注入并未成功，所以推荐大家尽量使用PreparedStatement，而且从效率上讲PreparedStatement 也高于Statement （很多网上的文章，包括介绍jdbc的书籍是这么讲的，但是我实际测试的结果，貌似性能相差不大-jdk1.5+jbuilder2006+oracle 11g express + winxp环境）

 

文章标签：
SQL
Java
存储
数据库连接
应用服务中间件
前端开发
关系型数据库
Oracle
数据库
关键词：
Java学习
Java数据
Java存储过程
Java增删改查
存储过程数据
杨俊明
目录
相关文章
啦啦啦191
|
4月前
|
IDE Java 编译器
java编程最基础学习
Java入门需掌握：环境搭建、基础语法、面向对象、数组集合与异常处理。通过实践编写简单程序，逐步深入学习，打牢编程基础。
啦啦啦191
300 1
阿铭学Java
|
5月前
|
Java API 容器
Java基础学习day08-2
本节讲解Java方法引用与常用API，包括静态、实例、特定类型方法及构造器引用的格式与使用场景，并结合代码示例深入解析。同时介绍String和ArrayList的核心方法及其实际应用。
阿铭学Java
181 1
啦啦啦191
|
4月前
|
存储 Oracle Java
java零基础学习者入门课程
本课程为Java零基础入门教程，涵盖环境搭建、变量、运算符、条件循环、数组及面向对象基础，每讲配示例代码与实践建议，助你循序渐进掌握核心知识，轻松迈入Java编程世界。
啦啦啦191
428 0
八进智
|
4月前
|
负载均衡 Java API
grpc-java 架构学习指南
本指南系统解析 grpc-java 架构，涵盖分层设计、核心流程与源码结构，结合实战路径与调试技巧，助你从入门到精通，掌握高性能 RPC 开发精髓。
八进智
494 7
阿铭学Java
|
5月前
|
Java
Java基础学习day08-作业
本作业涵盖Java中Lambda表达式的应用，包括Runnable与Comparator接口的简化实现、自定义函数式接口NumberProcessor进行加减乘及最大值操作，以及通过IntProcessor处理整数数组，实现遍历、平方和奇偶判断等功能，强化函数式编程实践。
阿铭学Java
97 5
阿铭学Java
|
5月前
|
Java 程序员
Java基础学习day08
本节讲解Java中的代码块（静态与实例）及其作用，深入介绍内部类（成员、静态、局部及匿名）的定义与使用，并引入函数式编程思想，重点阐述Lambda表达式及其在简化匿名内部类中的应用。
阿铭学Java
177 5
阿铭学Java
|
5月前
|
Java
Java基础学习day07-作业
本作业包含六个Java编程案例：1）动物类继承与多态；2）加油卡支付系统；3）员工管理类设计；4）学生信息统计接口；5）USB设备控制；6）家电智能控制。综合运用抽象类、接口、继承、多态等面向对象技术，强化Java基础编程能力。
阿铭学Java
223 3
阿铭学Java
|
5月前
|
Java
Java基础学习day06-作业
本内容为Java基础学习作业，涵盖两个案例：一是通过Card类及其子类GoldenCard、SilverCard实现加油卡系统，体现封装与继承；二是通过Shape类及子类Circle、Rectangle演示多态与方法重写，强化面向对象编程理解。
阿铭学Java
116 1
阿铭学Java
|
5月前
|
设计模式 存储 Java
Java基础学习day07
本节讲解Java中的final关键字、单例设计模式、枚举类、抽象类与接口。涵盖常量定义、单例写法（饿汉式/懒汉式）、枚举特点及应用场景，以及抽象类与接口的使用与区别，助力掌握核心面向对象编程思想。
阿铭学Java
204 1
阿铭学Java
|
5月前
|
Java
Java基础学习day05-作业
本文为Java基础学习第五天作业，通过五个案例练习类与对象的定义、构造方法、set/get方法及成员方法的应用。涵盖女友、学生、教师、手机和电影等类的设计与测试，强化面向对象编程基础。
阿铭学Java
107 2

热门文章

最新文章

  • 1
    MySql存储过程总结
  • 2
    mysql存储过程及常用函数
  • 3
    SQL中存储过程中使用事务,并且加入异常处理机制.
  • 4
    通用分页存储过程真的有注入漏洞吗?
  • 5
    Mysql 存储过程、函数、触发器和视图的权限检查
  • 6
    sql 2000 分页存储过程
  • 7
    无限级分类(非递归算法/存储过程版/GUID主键)完整数据库示例_(1)表结构
  • 8
    sql生成（查询数据的存储过程）代码的存储过程
  • 9
    oracle存储过程的常用语法
  • 10
    Java中调用SQL Server存储过程示例
  • 1
    Java 设计模式之策略模式：灵活切换算法的艺术
    807
  • 2
    Java 设计模式之观察者模式：构建松耦合的事件响应系统
    430
  • 3
    Java 设计模式之状态模式：让对象的行为随状态优雅变化
    479
  • 4
    java零基础学习者入门课程
    428
  • 5
    Java 设计模式之责任链模式：优雅处理请求的艺术
    545
  • 6
    【Azure Storage Account】Java Code访问Storage Account File Share的上传和下载代码示例
    430
  • 7
    百宝箱开放平台 ✖️ Java SDK
    1416
  • 8
    《深入理解Spring》：现代Java开发的核心框架
    687
  • 9
    用Java语言实现一个自定义的ArrayList类
    206
  • 10
    从混沌到秩序：Java共享内存模型如何通过显式约束驯服并发？
    140

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0
    • 下一篇
    第五届伏魔挑战赛如约来袭，诚邀各路高手来战！