Java学习11.15（人口普查2）

dao层和DBUtil层

dao.java

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;


import com.User;

public class dao
{

    //添加
    //添加入Grade表里
    
    public boolean insert(Grade grade)
    {
        String sql="insert into test(hometype,roomtype,square,roomnumber,name,ID,sex,nation,xueli) values('"+grade.getroomtype()
        +"','"+grade.getroomtype()+"','"+grade.getsquare()+"','"+grade.getroomnumber()+"','"+grade.getname()+"','"+grade.getID()
        +"','"+grade.getsex()+"','"+grade.getNation()+"','"+grade.getxueli()+"')";
        System.out.println(sql);
        //insert语句：
        //insert INTO table_name (column1,column2,column3,...) VALUES (value1,value2,value3,...);
        //注意：insert这里 values(100,'李泽宇','"+bianliang+"')，数字可以直接上，字符串的话用 '',变量的话要用 '"++"'
        
        Connection conn=DBUtil.getConn();//数据库连接，加载驱动
        Statement state=null;//数据库操作
        try
        {
            state=conn.createStatement();//实例化Statement对象,方便对sql语句进行操作
            state.executeUpdate(sql);
            //执行数据库更新操作用于执行INSERT、UPDATE或DELETE语句以及SQLDDL（数据定义语言）语句，
            //例如CREATETABLE和DROPTABLE,（创建表和删除表）
        }catch(Exception e)//当try语句中出现异常时，会执行catch中的语句
          {
            e.printStackTrace();//捕获异常的语句
          }
         finally //finally作为异常处理的一部分，它只能用在try/catch语句中，并且附带一个语句块，表示这段语句最终一定会被执行（不管有没有抛出异常），经常被用在需要释放资源的情况下。
         {
             DBUtil.close(state, conn); //close释放资源
         }
        return false;
    }
    
        //删除
        //根据姓名删除
        
        public boolean delete(String name)
        {
            String sql="delete from test where name='"+name+"'"  ;
            //删除语句：
            //delete from table_name where some_colume=some_value
            
            Connection conn=DBUtil.getConn();
            Statement state=null;
            
            try
            {
                state=conn.createStatement();
                state.executeUpdate(sql);
            }catch (Exception e)
            {
                e.printStackTrace();
            }
            finally
            {
                DBUtil.close(state, conn);
                
            }
            return true;
        }
//        
        //修改
        //根据姓名修改
        
        public boolean update(Grade grade)
        {
            String sql="update test set sex='"+grade.getsex()+"',nation='"+grade.getNation()
            +"',hometype='"+grade.gethometype()+"',roomtype='"+grade.getroomtype()
            +"',roomnumber='"+grade.getroomnumber()+"',square='"+grade.getsquare()
            +"',ID='"+grade.getID()+"',name="+grade.getname()+"',xueli="+grade.getxueli();
            //update语句：
            //update table_name set column1=value1,column2=value2  where some_column=some_value;
            
            Connection conn=DBUtil.getConn();
            Statement state=null;
            
            try
            {
                state=conn.createStatement();   
                state.executeUpdate(sql);
            }catch (SQLException e)
            {
                e.printStackTrace();
            }
            finally
            {
                DBUtil.close(state, conn);
            }
            return false;
        }
        
        //查询
        //查询全部并存入list
        //List指的是集合.<>是泛型,里面指定了这个集合中存放的是什么数据
        //泛型是程序设计语言的一种特性。
        //允许程序员在强类型程序设计语言中编写代码时定义一些可变部分，
        //但是，那些部分在使用前必须作出指明。
        
        public  List<Grade> list()
        {
            String sql="select * from test ";
            //select语句
            //select * from tabel_name   这是查询所有，若要查询某一列
            //select column1_name,column2_name,column3_name from table_name
            List<Grade>list=new ArrayList<>();
            //给集合list创造（new）一个存储空间用于存放数据
            
            Connection conn=DBUtil.getConn();
            Statement state=null;
            ResultSet rs=null;
            
            try
            {
                state=conn.createStatement();
                rs=state.executeQuery(sql);
                Grade grade=null;
                while(rs.next()) //这里表示，当rs.next()有值得时候，即收到查询结果
                {
                    String NAME=rs.getString("name"); //注意：这里用双引号，ID是表grade_student里的ID列
                    String sex=rs.getString("sex");
                    String nation=rs.getString("nation");
                    String ID=rs.getString("ID");
                    String hometype=rs.getString("homeroom");
                    String roomtype=rs.getString("roomtype");
                    String roomnumber=rs.getString("roomnumber");
                    String xueli=rs.getString("xueli");
                    String square=rs.getString("square");
                    grade=new Grade(hometype,roomtype,square,roomnumber,NAME,ID,sex,nation,xueli);
                    list.add(grade); //表示，把bean里的数据存入到list当中
                }
            }
            catch (SQLException e)
            {
                e.printStackTrace();
            }
            finally
            {
                DBUtil.close(state, conn);
            }
            return list;
        }
        public boolean add1(User user) {
            // TODO Auto-generated method stub
            String sql = "SELECT * FROM user WHERE username='"+user.getUsername()+"' and password='"+user.getPassword()+"' ";
            Connection conn = DBUtil.getConn();
            Statement state = null;
            boolean f = false;
            ResultSet RS = null;

            try {
                state = conn.createStatement();
                RS=state.executeQuery(sql);
                if(RS.next()) {
                    f=true;
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                
                DBUtil.close(state, conn);
            }
            return f;

    }
        public Grade selectByName(String name) {
            // TODO Auto-generated method stub
            String sql="select * from test where name like '%"+name+"%'";
            Connection conn=DBUtil.getConn();
            Statement state=null;
            ResultSet rs=null;
            
            try {
                state=conn.createStatement();
                rs=state.executeQuery(sql);
                
                while(rs.next()) {
                     String name1=rs.getString("name"); //注意：这里用双引号，ID是表grade_student里的ID列
                     String sex=rs.getString("sex");
                     String nation=rs.getString("nation");
                     String ID=rs.getString("ID");
                     String hometype=rs.getString("homeroom");
                     String roomtype=rs.getString("roomtype");
                     String roomnumber=rs.getString("roomnumber");
                     String square=rs.getString("square");
                     String xueli=rs.getString("xueli");
                    Grade grade=new Grade(hometype,roomtype,square,roomnumber,name1,ID,sex,nation,xueli);
                
                    return  grade; 
              }
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally {
                DBUtil.close(rs, state, conn);
            }
    
            return null;
        
        }
        
}

DBUtil层

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


public class DBUtil {
    //联结字符串                                              //数据库名test
    public static String db_url = "jdbc:mysql://localhost:3306/room?serverTimezone=UTC";
    //数据库用户名
    public static String db_user = "root";
    //数据库密码名
    public static String db_pass = "123asd..00";
    
    public static Connection getConn () {
        
        //声明与数据库的连接并实例化为null
        Connection conn = null;
        
        try {
            //驱动程序名"
            Class.forName("com.mysql.cj.jdbc.Driver");//连接数据库
            //具体地连接到数据库——联接字符串（数据库名），联接用户名，联接密码名
            conn = DriverManager.getConnection(db_url, db_user, db_pass);
            
        } catch (Exception e) {
            e.printStackTrace();
        }
        
        return conn;
    }
    


    /**
     * 关闭连接
     * @param state
     * @param conn
     */
    public static void close (Statement state, Connection conn) {
        if (state != null) {
            try {
                state.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    
    public static void close (ResultSet rs, Statement state, Connection conn) {
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        if (state != null) {
            try {
                state.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

}