Java JDBC连接数据库的数据进行增删改封装工具类

JDBC相信大家在学习Java基础的时候都学习过的、那么要怎么在项目中使用的话还是比较麻烦的、福利来了、这次给大家分享一个JDBC的封装类、有了这个封装类在项目中使用就会方便很多

1、封装类

package com.com;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class JDBCTools {

    /**
     * @throws Exception
     */
    static Connection conn = null;
    static Statement st = null;
    static ResultSet rs = null;

    public static void mains() {

        try {
            Class.forName("oracle.jdbc.OracleDriver");
            conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521/XE", "mysql", "123456");
            st = conn.createStatement();
            rs = st.executeQuery("select numno,ename from dept");

            while (rs.next()) {
                System.out.println(rs.getInt("numno") + "---" + rs.getString("ename"));
            }

        } catch (Exception e) {
            e.printStackTrace();
        } /*
             * finally { try { if (rs != null) rs.close(); if (st != null)
             * st.close(); if (conn != null) conn.close(); } catch (SQLException
             * e) { e.printStackTrace(); } }
             */
    }

    // 添加数据
    public static void add(String num1, String name1) throws SQLException {
        int addRe = st.executeUpdate("insert into dept (numno,ename) values (" + num1 + ",'" + name1 + "')");
        System.out.println("******添加操作结果是:" + addRe);

    }

    // 删除数据
    public static void delete(String num2) throws SQLException {
        int dele = st.executeUpdate("delete from dept where numno=" + num2 + "");
        System.out.println("******删除操作结果是:" + dele);
    }

    // 修改数据
    public static void alters(String num3, String name2) throws SQLException {
        int alt = st.executeUpdate("update dept set ename='" + name2 + "'where numno=" + num3 + "");
        System.out.println("******删除操作结果是:" + alt);
    }

}

2、调用类（执行类，测试类）

import java.sql.SQLException;
import java.util.Scanner;

public class JDBCTest {
    /**
     * @param args
     */
    public static void main(String[] args) {
        Scanner sca = new Scanner(System.in);
        boolean flag = true;
        while (flag) {
            System.out.println(" 1.添加 2.删除 3.修改 4.退出 ");
            int num = 0;
            try {
                num = sca.nextInt();
            } catch (Exception e) {
                System.out.println("异常");
                break;
            }
            switch (num) {
            case 1:
                System.out.println("添加前的数据");
                JDBCTools.mains();
                System.out.println("请输入您添加的编号:");
                String num1 = sca.next();
                // 保证输入的是数字
                for (int i = num1.length(); --i >= 0;) {
                    int nums = num1.charAt(i);
                    if (num1.length() == 4 && nums >= 48 && nums <= 57) {
                        System.out.println("请输入您添加的名称:");
                        String name1 = sca.next();
                        try {
                            JDBCTools.add(num1, name1);
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                        System.out.println("添加后的数据--");
                        JDBCTools.mains();
                        i = -i;
                    } else {
                        System.out.println("输入内容有误，请输入4位数数字");
                        break;
                    }
                }

                break;
            // 删除数据
            case 2:
                System.out.println("删除前的数据");
                JDBCTools.mains();
                System.out.println("请输入您删除的编号:");
                String num2 = sca.next();
                // 数字
                for (int i = num2.length(); --i >= 0;) {
                    int nums1 = num2.charAt(i);
                    if (num2.length() == 4 && nums1 >= 48 && nums1 <= 57) {
                        try {
                            JDBCTools.delete(num2);
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                        System.out.println("删除后的数据--");
                        JDBCTools.mains();
                        i = -i;
                    } else {
                        System.out.println("输入内容有误，请输入4位数数字");
                        break;
                    }
                }

                break;
            case 3:
                // 修改数据
                System.out.println("修改前的数据");
                JDBCTools.mains();
                System.out.println("请输入您修改的编号:");
                String num3 = sca.next();
                // 数字
                for (int i = num3.length(); --i >= 0;) {
                    int nums2 = num3.charAt(i);
                    if (num3.length() == 4 && nums2 >= 48 && nums2 <= 57) {
                        System.out.println("请输入您修改的名称:");
                        String name2 = sca.next();
                        try {
                            JDBCTools.alters(num3, name2);
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                        System.out.println("修改后的数据--");
                        JDBCTools.mains();
                        i = -i;
                    } else {
                        System.out.println("输入内容有误，请输入4位数数字");
                        break;
                    }
                }

                break;
            case 4:
                System.out.println("您已退出系统！");
                flag = false;
                break;
            default:
                System.out.println("请输入规定的数字!");
                break;
            }
        }
    }
}

上面就是JDBC封装类的代码以及JDBC封装类的调用方法、都是用static写的、可以自己改造的