欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Jdbc工具类

程序员文章站 2024-03-22 23:53:10
...

JDBC工具类对MySql数据库的操作

导入连接mysql的jar包

Jdbc工具类

使用jdbc.properties文件配置数据库资源

使用properties文件设置连接数据库需要的数据

Jdbc工具类

读取jdbc.properties数据库资源的工具类

properties文件都是根据键值对关系,通过key值得到value值、


public class ConfigUtil {
    /**
     * 工具类,获取jdbc的配置资源,通过key-value的关系得到配置资源
     * @param key  
     * @return  
     */
    public static String getValue(String key){
        Properties pro = new Properties();

        //得到文件输入流
        InputStream input = ConfigUtil.class.getResourceAsStream("/jdbc.properties");

        String value = null ;
        try {
            //加载文件输入流
            pro.load(input);

            value= pro.getProperty(key);

        } catch (IOException e) {

            e.printStackTrace();
        }
        return value;
    }
}

jdbc操作表

/**
 * jdbc连接操作工具
 * @author admin
 *
 */
public class JdbcUntil {
    /**
     * 加载驱动,向驱动管理注册
     */
    static{
        try {
            Class.forName(ConfigUtil.getValue("driver"));
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    /**
     * 获取连接
     * @return
     */
    private static Connection getConn(){
        Connection conn = null;
         try {
            conn = DriverManager.getConnection(ConfigUtil.getValue("url"), //加载url
                        ConfigUtil.getValue("username"), ConfigUtil.getValue("password"));//加载用户名和密码

            return conn;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        return null;

    }

    //释放连接
    private static void colse(ResultSet rs,PreparedStatement ps,Connection conn){

            try {
                if(rs!=null){
                   rs.close();//关闭ResultSet
                }
                if(ps!=null){
                   ps.close();//关闭PreparedStatement
                }
                if(conn!=null){
                   conn.close();//关闭Connection
                }
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

    }

    /**
     * 对数据库进行,增加、删除、修改
     * @param sql
     * @param params
     * @return
     */
    public static int updateStu(String sql,Object[] params){
        PreparedStatement ps = null;
        Connection conn = null;
        int result = 0;//用户执行添加删除和修改的时候所影响数据库的行数 
        try {
             //获取连接
             conn = getConn();

             ps = conn.prepareStatement(sql);
            //向sql语句注入参数
             if(params!=null && params.length>0){
             for(int i=0;i<params.length;i++){
                 ps.setObject(i+1, params[i]);//向sql语句注入参数
             }
             }
             result = ps.executeUpdate();//执行sql语句

        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            colse(null, ps, conn);
        }

        return result;
    }


    /**
     * 查询单个的数据的工具类
     * @param args
     */

    public static Object getStu(String sql,Object[] params,Class<?> clz){
        Connection conn = null;
        ResultSet rs = null;
        PreparedStatement ps = null;
        conn = JdbcUntil.getConn();

        try {

            ps = conn.prepareStatement(sql);


        if(params!=null && params.length>0){
            for(int i = 0;i<params.length;i++){
                ps.setObject(i+1, params[0]);

            }

        }
        rs = ps.executeQuery();
            //当rs没有数据是,返回的是false
                if(!rs.next()){
                    return null;

                }

            return doResultSet(rs, clz);

        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            colse(rs, ps, conn);
        }




        return null;
    }




    /**
     * 将rs里面的参数,封装到对象里面,用于
     * @param rs  查询的结果
     * @param clz 需要封装的对象
     * @return 封装完成的对象
     */
    private static Object doResultSet(ResultSet rs,Class<?> clz){

        //ResultSetMetaData可用于获取关于 ResultSet 对象中列的类型和属性信息的对象
        ResultSetMetaData rsmd = null;
        try {
            rsmd = rs.getMetaData();
            //获取rs的列数
            int numberOfColunm = rsmd.getColumnCount();

            //通过反射实例化Object对象
            Object bean = clz.newInstance();

            //通过获取的列,来读取字段
            for(int i = 0 ; i<numberOfColunm;i++){
                //获取当前列的记录(获取当前列的值)
                Object colValue = rs.getObject(i+1);
                //获取当前列名
                String colName = rsmd.getColumnName(i+1);

                //System.out.println(colName);
                //获取默认的属性
                Field file = clz.getDeclaredField(colName);
                //当参数为true的时候不检查访问权限
                file.setAccessible(true);
                file.set(bean, colValue);


            }
            return bean;


        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (InstantiationException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (NoSuchFieldException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SecurityException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        //

        return null;

    }


    /**
     * 查询多个的学生集合
     * 
     * @param sql
     * @param params 
     * @param clz
     * @return
     */
    public static List<?> getStuList(String sql,Object[] params,Class<?> clz){
        Connection conn = null ;
        PreparedStatement ps = null;
        ResultSet rs = null;

        conn = getConn();
        try {
            ps = conn.prepareStatement(sql);
            if(params != null && params.length>0){
                for(int i = 0; i<params.length;i++){
                    ps.setObject(i+1, params[i]);
                }

            }
            rs = ps.executeQuery();



            return   doResultSetList(rs,clz);

        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            colse(rs, ps, conn);
        }


        return null;
    }

    /**
     * 操作Result rs,将rs里面的数据取出来放到集合里面
     * @param rs
     * @param clz
     * @return
     */
    private static List<?> doResultSetList(ResultSet rs,Class<?> clz){
        try {
            //创建集合用于保存查询到的数据
            List<Object> list = new ArrayList<Object>();


            while(rs.next()){

                ResultSetMetaData rsmd = rs.getMetaData();

                //获取列数
                int numberOfColunm = rsmd.getColumnCount();
                //创建实例
                Object bean = clz.newInstance();
                for(int i = 0;i<numberOfColunm;i++){
                    //获取当前列的记录
                    Object value = rs.getObject(i+1);

                    //获取当前列的名称
                    String  colName = rsmd.getColumnName(i+1);

                    //获取bean的属性
                    Field field = clz.getDeclaredField(colName);

                    field.setAccessible(true);
                    //对象的字段赋值
                    field.set(bean,value);

                }
                //将对象添加集合里面
                list.add(bean);
            }

            return list;

        } catch (SQLException | InstantiationException | IllegalAccessException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (NoSuchFieldException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SecurityException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        return null;
    }

测试

  1. 创建数据表ssk
use myschool;
drop table if exists ssk;
create table ssk(
id int not null primary key auto_increment,
name varchar(32),
gender int,
address varchar(32)
);


alter table ssk auto_increment=95001;
  1. 创建Ssk对象
public class Ssk {
    private int id;
    private String name;
    private int gender;
    private String address
    .....
  1. 测试添加数据

public static void main(String[] args) {




        //添加数据的sql语句
        String sql = "insert into ssk(name,gender,address) value(?,?,?)";
        //sql的参数
        Object[] params = {"哇哇哇",0,"深圳"};

        //执行sql语句
        int reuslt = JdbcUntil.updateStu(sql, params);
        System.out.println(reuslt);

}
  1. 查询单个数据
public static void main(String[] args) {
        String sql ="select * from ssk where id = ?";

        Object[] params = {95002};
        Ssk ssk = (Ssk) JdbcUntil.getStu(sql, params, Ssk.class);
        System.out.println(ssk)*/;

}
  1. 查询多条数据
public static void main(String[] args) {
        String sql = "select * from ssk where gender=?";

        Object[] params = {1};

        List<Ssk> list = (List<Ssk>) JdbcUntil.getStuList(sql, params, Ssk.class);

        for(Ssk sk:list){
            System.out.println(sk);
        }

}
相关标签: jdbc工具类