我的学习之JDBC操作数据库

zhangjie

import java.sql.*;
import java.util.Scanner;

/**
*
* @Description:
* @Author:
* @Date: ${YEAR}-${MONTH}-${DAY} ${TIME}
*/public class Main {
    public static void main(String[] args) {
        if (login()){
           add();
           update();
           delete();

        }else {
            System.out.println("登陆失败");
        }
    }
    private static void delete() {
        String sql = "delete from score where sno=? and cno=?";
        Scanner input=new Scanner(System.in);
        System.out.println("请输入删除的学生编号");
        int sno=input.nextInt();
        System.out.println("请输入删除的课程编号");
        int cno=input.nextInt();
        int result = BaseDao.executeupdate(sql,sno,cno);
        if (result > 0) {
            System.out.println("删除成功");
        } else {
            System.out.println("删除失败");
        }
    }
    private static void add() {
        String sql = "insert into score values(?,?,?)";
        Scanner input=new Scanner(System.in);
        System.out.println("请输入添加的学生编号");
        int sno=input.nextInt();
        System.out.println("请输入添加的课程编号");
        int cno=input.nextInt();
        System.out.println("请输入添加的成绩");
        double degree=input.nextDouble();
        int result = BaseDao.executeupdate(sql,sno,cno,degree);
        if (result > 0) {
            System.out.println("添加成功");
        } else {
            System.out.println("添加失败");
        }
    }
    private static void update() {
        String sql="update score set degree=? where sno=? and cno=?";
        Scanner input=new Scanner(System.in);
        System.out.println("请输入准备修改的成绩");
        double degree=input.nextDouble();
        System.out.println("请输入学生编号");
        int sno=input.nextInt();
        System.out.println("请输入课程");
        int cno=input.nextInt();
        int result = BaseDao.executeupdate(sql,degree,sno,cno);
        if (result > 0) {
            System.out.println("修改成功");
        } else {
            System.out.println("修改失败");
        }
    }
    private static void  excuteQuery(){
        Connection connection=null;
        Statement statement=null;
        ResultSet resultSet=null;
        String sql="SELECT * FROM score";
        try {
            connection=BaseDao.createConnection();
            statement=connection.createStatement();
            resultSet=statement.executeQuery(sql);
            while (resultSet.next()){
                System.out.print(resultSet.getString("sno")+"\t");
                System.out.print(resultSet.getString("cno")+"\t");
                System.out.println(resultSet.getString(3));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            BaseDao.closeAll(connection,statement,resultSet);
        }
    }
    private static boolean login(){
        Scanner input=new Scanner(System.in);
        System.out.print("请输入用户：");
        String name=input.next();
        System.out.print("请输入密码：");
        String pwd=input.next();
        String sql="SELECT count(*) FROM admin WHERE userName=? AND userpwd=?";
        Connection connection=null;
        PreparedStatement statement=null;
        ResultSet resultSet=null;
        try {
            connection=BaseDao.createConnection();
            //statement=connection.createStatement();
            statement=connection.prepareStatement(sql);
            statement.setObject(1,name);
            statement.setObject(2,pwd);
            resultSet=statement.executeQuery();
            if(resultSet.next()){
                int result=resultSet.getInt(1);
                return result>0;
            }
        } catch (SQLException e) {
           e.printStackTrace();
        }finally {
            BaseDao.closeAll(connection,statement,resultSet);
        }
        return false;
    }
}




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

/**
* @Description:
* @Author:
* @Date: 2022-11-10 10:34
*/
public class BaseDao {
    static String url="";
    static String user="";
    static String pwd="";
    static String driver="";
    static {
        init();

        try {
            Class.forName(driver);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

    private static void init() {
        Properties properties=new Properties();
        try {
            properties.load(BaseDao.class.getResourceAsStream("jdbc.properties"));
        } catch (IOException e) {
            e.printStackTrace();
        }
        url=properties.getProperty("jdbc.url");
        user=properties.getProperty("jdbc.username");
        pwd=properties.getProperty("jdbc.password");
        driver=properties.getProperty("jdbc.driver");
    }

    public static Connection createConnection(){
        Connection connection=null;
        try {
            connection=DriverManager.getConnection(url,user,pwd);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return connection;
    }
    public static void  closeAll(Connection connection, Statement statement, ResultSet resultSet){
            try {
                if (resultSet!=null) resultSet.close();
                if (statement!=null) statement.close();
                if (connection!=null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
    }

    public static int executeupdate(String sql,Object ...obj){
        Connection connection=null;
        PreparedStatement statement=null;
        try {
            connection=createConnection();
            statement=connection.prepareStatement(sql);
            for(int i=0;i<obj.length;i++){
                statement.setObject(i+1,obj);
            }
            return statement.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            closeAll(connection,statement,null);
        }
        return 0;
    }
}