java連接mysql以及增刪改查操作

java連接數據庫的代碼基本是固定的，步驟過程覺得繁瑣些，代碼記起來對我來說是鬧挺。直接上代碼：

（溫馨提醒：你的項目提前導入連接數據庫的jar包才有的以下操作 ）

class DBConnection{
    
//    驅動類名
    String driver="com.mysql.jdbc.Driver";
//    URL格式,最后為數據庫名
    String url="jdbc:mysql://localhost:3306/javaTest?useUnicode=true&characterEncoding=UTF8";　　//JavaTest為你的數據庫名稱   7     String user="root";
    String password="123456";
    Connection  coon=null;
    public DBConnection(){
        try{
//            加載驅動程序
            Class.forName(driver);
            coon=(Connection)DriverManager.getConnection(url,user,password);
            if(!coon.isClosed()){
                System.out.println("成功連接數據庫！");
            } 
        }catch (Exception e){
                e.printStackTrace();
            }
    }
    public void close(){
        try{
            this.coon.close();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
//    增加數據
    public void add(String name,int age,String gender){
//        String sql="insert into usrInfo(username,gender,age) values(?,?,?)";　　//向usrInfo表中插入數據
        String sql="insert into usrInfo(age,gender,username) values('"+age+"','"+gender+"','"+name+"')";
        try{
            PreparedStatement preStmt=(PreparedStatement)this.coon.prepareStatement(sql);
//            preStmt.setString(1, name);
//            preStmt.setInt(3, age);
//            preStmt.setString(2, gender);　　//和上面的注釋的一塊組成另外一種插入方法
            preStmt.executeUpdate();
            System.out.println("插入數據成功！");
            preStmt.close();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    
//    查詢
    public void select(){
        String sql="select * from usrInfo";　　//查詢usrInfo表中的信息
        
        try{
            Statement stmt=(Statement)this.coon.createStatement();
            ResultSet rs=(ResultSet)stmt.executeQuery(sql);　　//得到的是結果的集合
            System.out.println("--------------------------------");
            System.out.println("姓名"+"\t"+"年齡"+"\t"+"性別");
            System.out.println("--------------------------------");
            while(rs.next()){
                String name=rs.getString("username");
                int age=rs.getInt("age");
                String gender=rs.getString("gender");
                System.out.println(name+"\t"+age+"\t"+gender);
            }
            stmt.close();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    
//    更改數據
    
    public void update(String name,int age){
        String sql="update usrInfo set age=? where username=?";　　//推薦使用這種方式，下面的那種注釋方式不知道為啥有時候不好使
//        String sql="update usrInfo set age="+age+" where username='"+name+"'";　　
        try{
            PreparedStatement prestmt=(PreparedStatement)this.coon.prepareStatement(sql);
            prestmt.setInt(1, age);
            prestmt.setString(2,name);
            prestmt.executeUpdate();
            
            
//            Statement stmt=(Statement)this.coon.createStatement();
//            stmt.executeUpdate(sql);
            System.out.println("更改數據成功！");
            prestmt.close();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
    
//    刪除數據
    public void del(String name){
        String sql="delete from usrInfo where username=?";
        try{
            PreparedStatement prestmt=(PreparedStatement)this.coon.prepareStatement(sql);
            prestmt.setString(1, name);
            prestmt.executeUpdate();
            System.out.println("刪除數據成功！");
            prestmt.close();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

 

在主類中對其創建實例，實例中構造方法完成數據庫的連接操作，實例調用增刪改查方法進行對數據庫信息的操作

public class mysqlTest {
    public static void main(String args[]){
        Scanner in=new Scanner(System.in);
        DBConnection db=new DBConnection();
        
//        插入數據
        System.out.println("輸入姓名，年齡，性別：");
        String name=in.next();
        int age=in.nextInt();
        String gender=in.next();        
        db.add(name, age, gender);
        
//        查詢數據
        db.select();
        
//        修改數據
//        String name=in.next();
//        int age=in.nextInt();
//        db.update(name, age);
        
        
//        刪除數據
//        String name=in.next();
//        db.del(name);
//        
//        db.close();
    }

}

 

原創不易，尊重版權。轉載請注明出處：http://www.cnblogs.com/xsmile/