标签：ps jdbc String 学习 connection 自用 sql import public

以下问题为自己编程过程中遇到的问题，如果各路神通觉得我出现的问题比较低级。可以给出解决意见，但不要乱喷。心灵脆弱禁不起打击，本博作为我编程路上跳坑记录，学会之后会过来填平。但不知道什么时候才能学会。

1、针对一张表查询一条数据的通用方法

实体类

package com.company.preparedstatement.crud;

public class course {
    public String CId;
    public String Cname;
    public String TId;

    public course() {
    }

    public course(String CId, String cname, String TId) {
        this.CId = CId;
        Cname = cname;
        this.TId = TId;
    }

    public String getCId() {
        return CId;
    }

    public void setCId(String CId) {
        this.CId = CId;
    }

    public String getCname() {
        return Cname;
    }

    public void setCname(String cname) {
        Cname = cname;
    }

    public String getTId() {
        return TId;
    }

    public void setTId(String TId) {
        this.TId = TId;
    }

    @Override
    public String toString() {
        return "course{" +
                "CId='" + CId + '\'' +
                ", Cname='" + Cname + '\'' +
                ", TId='" + TId + '\'' +
                '}';
    }
}

工具类

package com.company.preparedstatement.Utils;

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

public class JDBCUtils {
    public static Connection getConnection() throws IOException, ClassNotFoundException, SQLException {
        //1、获取
        InputStream is = ClassLoader.getSystemClassLoader().getSystemResourceAsStream("db.properties");
        Properties properties = new Properties();
        properties.load(is);
        String driverClass = properties.getProperty("driverClass");
        String url = properties.getProperty("url");
        String user = properties.getProperty("user");
        String password = properties.getProperty("password");
        Class.forName(driverClass);
        Connection connection = DriverManager.getConnection(url, user, password);
        is.close();
        return connection;
    }

    /*
    * 关闭连接和Statement的操作
    * */
    public static void closeResource(Connection connection, PreparedStatement preparedStatement){
        try {
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            preparedStatement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    public static void closeResource(Connection connection, PreparedStatement preparedStatement, ResultSet resultSet){
        try {
            connection.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            preparedStatement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            resultSet.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

db.properties

driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbc
user=root
password=123456

查询一张表数据的方法

@org.junit.Test
package com.company.preparedstatement.crud;

import com.company.preparedstatement.Utils.JDBCUtils;

import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;

public class Test {
    //针对一张表查询一条数据的通用方法
    public course test4(String sql,Object... args) {

        Connection connection = null;
        PreparedStatement ps = null;
        ResultSet resultSet = null;
        try {
            //创建连接
            connection = JDBCUtils.getConnection();
            //获取对象
            ps = connection.prepareStatement(sql);
            //获取占位符对应的值
            for(int i = 0;i < args.length;i++){
                ps.setObject(i+1,args[i]);
            }

            //执行返回结果集
            resultSet = ps.executeQuery();

            //获取结果集的元数据：ResultSetMetaData
            ResultSetMetaData metaData = resultSet.getMetaData();

            //获取字段值个数
            int columnCount = metaData.getColumnCount();

            //判断有没有返回值
            if(resultSet.next()){
                //创建一个对象
                course cs = new course();
                //处理一行数据中的每一个列
                for(int i = 0;i < columnCount;i++){
                    //获取列值
                    Object columValue = resultSet.getObject(i + 1);

                    //获取每个列的列名
                    String columName = metaData.getColumnName(i + 1);

                    //给对象中的给对象中columName属性用set方法赋值为columvalue:通过反射实现
                    //通过反射获取属性
                    Field field = course.class.getDeclaredField(columName);
                    //属性值可能是私有的，设置一下
                    field.setAccessible(true);
                    //给对象的属性赋值
                    field.set(cs,columValue);
                }
                //返回对象
                return cs;
            }

        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            //关闭资源
            JDBCUtils.closeResource(connection,ps,resultSet);
            return null;
        }
    }
}

测试方法

public void test44(){
    String sql = "select * from course where CId=?";
    course course = test4(sql, "01");
    System.out.println(course);
}

出现的问题：

​ try中包含的代码可以顺利的执行，也能成功的向创建的对象中添加相应的数据，但到return的时候无论如何都会返回null。程序返回多条数据的时候只执行一次循环就会return null结束程序。

代码存在缺陷：

​ 假如try中顺利执行也成功return就无法继续执行下面的代码关闭资源，程序硬伤

大发现

//cs.getClass()和course.class return出的内容不同！！！！
Field declaredField = cs.getClass().getDeclaredField(columName);

cs.getClass()：可以返回一条数据

course.class ：直接return null

oh,my god!一定是我太无知了

emmmmmmm他们又返回一样的值了，我真的不懂这是什么魔鬼操作！！！

2、数据库事务回滚

package com.company.trans;

import com.company.Utils.JDBCUtils;
import org.junit.Test;

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

public class TransactionTest {
    /**
     * 针对于数据表user_table
     *
     * */
    @Test
    public void testUpdate()
    {
        String sql1 = "update sc set score = score - 10 where SId = ?";
        String sql2 = "update sc set score = score + 10 where SId = ?";

        update(sql1,"06");
        System.out.println(10/0);
        update(sql2,"07");
        System.out.println("分数交换成功！");
    }
    //=================没有考虑数据库事务情况下的分数同时增加缩小的操作===================
    //增删改通用操作
    public void update(String sql,Object... agrs) {

        Connection connection = null;
        PreparedStatement ps = null;
        try {
            //1.获取数据库连接
            connection = JDBCUtils.getConnection();
            //2.预编译sql语句，返回PrepareStatement的实例
            ps = connection.prepareStatement(sql);
            //3.添加占位符
            for(int i = 0;i < agrs.length;i++){
                ps.setObject(i + 1,agrs[i]);
            }
            //4.执行
            ps.execute();
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            //5.关闭资源
            JDBCUtils.closeResource(connection,ps);
        }
    }

    //=====================考虑数据库事务的的分数交换操作=====================
    public int update1(Connection connection,String sql,Object... agrs) {

        PreparedStatement ps = null;
        try {
            //2.预编译sql语句，返回PrepareStatement的实例
            ps = connection.prepareStatement(sql);
            //3.添加占位符
            for(int i = 0;i < agrs.length;i++){
                ps.setObject(i + 1,agrs[i]);
            }
            //4.执行
            ps.execute();
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            //5.关闭资源
            JDBCUtils.closeResource(null,ps);
        }
        return 0;
    }

    @Test
    public void updateTest(){
        Connection connection = null;
        try {
            connection = JDBCUtils.getConnection();
            //将数据库语句自动提交设置为false
            connection.setAutoCommit(false);
            String sql1 = "update examstudent set Grade = Grade - 10 where FlowID = ?";
            update1(connection,sql1,2);

            //设置异常
            //System.out.println(10/0);

            String sql2 = "update examstudent set Grade = Grade + 10 where FlowID = ?";
            update1(connection,sql2,3);
            //手动提交事务
            connection.commit();
        } catch (Exception e) {
            try {
                //出现异常
                connection.rollback();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
            e.printStackTrace();
        }finally {
            JDBCUtils.closeResource(connection,null);
        }

    }
}

存在问题，由于数据库关闭方法中的对象在不同的位置关闭，其中就有一方为null，有一个为null系统会报空指针异常

标签：ps,jdbc,String,学习,connection,自用,sql,import,public
来源： https://blog.csdn.net/qq_43130076/article/details/121762701

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