[大数据]MVC架构连接数据库以及进行数据库的增删查改操作

创建一个DatabaseAccess的java文件，连接数据库，代码如下：

public class DatabaseAccess {
    private  String drv="com.mysql.jdbc.Driver";
    private String url="jdbc:mysql://localhost:3306/j";//写数据库所在的地址
    private String usr=                                           //MySQL的账号
    private String pwd=                                         //MySQL的密码
     
     public DatabaseAccess(){
         try{
             Class.forName(drv);
             conn=DriverManager.getConnection(url,usr,pwd);
             stm=conn.createStatement();
         }catch(Exception e){
             System.out.println(e.toString());
         }
     }
     public boolean update(String sql){
         boolean b=false;
         try{
             stm.executeUpdate(sql);
             b=true;
         }catch(Exception e){
             System.out.println(e.toString());
         }
         return b;
     }
     public ResultSet query(String sql){
         try{
             rs=stm.executeQuery(sql);
         }catch(Exception e){
             System.out.println(e.toString());
         }
         return rs;
     }
     public boolean isHaveResult(String sql){
         boolean b=false;
         try{
             rs=stm.executeQuery(sql);
             if(rs.next()){
                 b=true;
             }
         }catch(Exception e){
             System.out.println(e.toString());
         }
         return b;
     }
     public void close(){
         try{
                if(rs!=null){
                rs.close();}
                if(stm!=null){
                stm.close();}
            if (conn!=null){
               conn.close();
       } 
            }catch(SQLException e){
                System.out.println(e.toString());
            }
     }
    
}

当需要在任何一个地方需要数据库操作时，只需要 DatabaseAccess db=new DatabaseAccess()这一行代码即可调用数据库，不需要每次都进行连接，减少代码量。
例：进行查询操作：

boolean isVaild=false;
        DatabaseAccess db=new DatabaseAccess();
        String sql="select * from user where username='"+username+"'";
        if(db.isHaveResult(sql)){
            isVaild=true;
        }
        db.close();
        return isVaild;

插入操作：

DatabaseAccess db=new DatabaseAccess();
        String sql="insert into user(username,password,email)values('"+username+"','"+password+"','"+email+"')";
        db.update(sql);
        db.close();  

跟新操作：

DatabaseAccess db=new DatabaseAccess();
          String sql="update user set"+field+"='"+value+"'where username='"+username+"'";
          db.update(sql);
           db.close();