JDBC学习之statement简单增删改


JDBC学习之statement简单增删改

一.快速入门

(一) 步骤

1. 导入驱动jar包
2. 注册驱动
3. 获取数据库连接对象connection
4. 定义sql
5. 获取执行sql语句的对象statement
6. 执行sql,接受返回结果
7. 处理结果
8. 释放资源

1.导入驱动Jar包:

  • a.下载jar数据包,新建一个lib包,将jar数据包装入
    Image.png
  • b.右键>Build Path>add to Build Path
    Image1.png

2.注册驱动:告诉程序该使用哪一个数据库驱动jar

  • 方法:static void registerDriver(Driver driver):注册与给定的驱动程序DriverManager
  • 例子:注册mysql驱动:

    Class.forName("com.mysql.jdbc.Driver");

3.获取数据库的连接对象

  • a.方法:static Connection getConnection(String url,String user, String password)
  • b.参数

    • url:指定连接的路径

      • 语法:jdbc :mysql://ip地址(域名) :端口号/数据库名称
      • 例子:jdbc:mysql://localhost:3306/b
        如果连接的是本机mysql服务器,并且mysql服务端口是3306,则url可以简写为jdbc:mysql:///:数据库名称
    • user:用户名
    • password :密码
  • c.例子:

    Connection conn=(Connection) DriverManager.getConnection("jdbc:mysql://localhost:3306/b", "root", null);
    

4.定义sql:

  • 只需要把sql定义为String类型,sql为对应的数据库的语句

5.获取执行sql语句的对象statement(本次只使用statement)

  • a.statement方法: createstatement();
  • b.preparedstatement方法:preparestatement(string sql)
  • c.例子:(conn为数据库连接对象)Statement

      statm=(Statement) conn.createStatement();
    

6.执行sql:执行增删改查区别的步骤,
A.执行sql

  • (1)boolean execute(String sql):可以执行任意的sql
  • (2)int executeupdata(String sql):执行DML(insert,update,delete)语句,DDL(create ,alter,drop)语句

       返回值:影响的行数,可以通过这个影响的行数判断DML是否执行成功,返回值>0则执行成功,反之,则失败  
    
  • (3) ResultSet executeQuery(String sql):执行DQL(select)语句
  • (4) ResultSet结果集对象,封装查询结果

    • next():游标向下移动一行
    • getXXX(参数):获取对象
    • XXX代表数据类型,如:int getInt(),String getstring(1);

                 String代表列名称,如getdouble("balance");
      
    • 使用步骤

      • 1.游标向下移动一行
      • 2.判断是否存在数据
      • 3.获取数据:boolean next();判断是否为最后一行,true有数据false没有数据

二.详细例子演示:

1.简单的示例

package jdbcdemo;
import java.sql.DriverManager;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class jdbcdemo {
      public static void main(String[] args) throws Exception {
            //1.导入驱动jar包
            //2.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //3.获取数据库连接对象connection
            Connection conn=(Connection)DriverManager.getConnection("jdbc:mysql://localhost:3306/b", "root",  null);
            //4.定义sql
            String sql = "update student set name='123' where id=1";//修改id为1的学生的名字
            //5.获取执行sql语句的对象statement
            Statement stat=(Statement) conn.createStatement();
            //6.执行sql,接受返回结果
            int count=stat.executeUpdate(sql);
            //7.处理结果
            System.out.println(count);
            //8.释放资源
            stat.close();
            conn.close();
      }
}

结果
Image2.png

2.升级版

对于1的例子

  • a.当在执行的过程中,如果出现错误或者异常,不能释放所占用的资源,即stat.close()不能执行,所以将代码stat,close()用try-finally包起来。
  • b.在包装中也要注意,当stat要关闭,要stat已经执行了,才能关闭,所以当stat为空的时候不能关闭,所以要避免空指针异常
package jdbcdemo1;
import java.sql.DriverManager;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class jdbcdemo1 {
  public static void main(String[] args){
        //1.导入驱动jar包
        Connection conn = null;
        Statement stat = null;
        try {
              //2.注册驱动
              Class.forName("com.mysql.jdbc.Driver");
              //3.获取数据库连接对象connection
              
              conn = (Connection)  DriverManager.getConnection("jdbc:mysql://localhost:3306/b", "root",  null);
              //4.定义sql
              String sql = "update student set name='123' where  id=1";
              //5.获取执行sql语句的对象statement
              stat=(Statement) conn.createStatement();
              //6.执行sql,接受返回结果
              int count=stat.executeUpdate(sql);
              //7.处理结果
              System.out.println(count);
              
        } catch (ClassNotFoundException e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
        }
        catch (SQLException e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
        }finally {
              /*
               * 避免空指针异常
               */
              if(stat!=null){
                    try {
                          stat.close();
                          } catch (SQLException e) {
                    // TODO Auto-generated catch block
                                e.printStackTrace();
                                }
              }
              if(conn!=null) {
                    try {
                          conn.close();
                          } catch (SQLException e) {
                    // TODO Auto-generated catch block
                                e.printStackTrace();
                                }
                    }
              }
  }

3.增删改查statement执行sql对象

  • a.执行sql

    • boolean execute(String sql):可以执行任意的sql
    • int executeupdata(String sql):执行DML(insert,update,delete)语句,DDL(create ,alter,drop)语句
  • b.返回值:影响的行数,可以通过这个影响的行数判断DML是否执行成功,返回值>0则执行成功,反之,则失败

(1)inset添加(红色为需要修改的位置其他不变)

package jdbcdemo;
import java.sql.DriverManager;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class jdbcdemo2 {
      public static void main(String[] args){
            Statement stmt=null;
            Connection conn=null;
            try {
                  Class.forName("com.mysql.jdbc.Driver");
                  //3.获取数据库连接对象connection
                  conn=(Connection)  DriverManager.getConnection("jdbc:mysql://localhost:3306/b", "root",  null);
                  String sql="INSERT INTO student(id,NAME,age,class_num)  VALUES (4,\"张无忌\",18,1);";//添加的数据
                  
                  stmt=(Statement) conn.createStatement();
                  int count=stmt.executeUpdate(sql);
                  if(count>0) {
                  System.out.println("添加成功");
                  }else {
                        System.out.println("添加失败");
                  }
            } catch (ClassNotFoundException e) {
                  // TODO Auto-generated catch block
                  e.printStackTrace();
            } catch (SQLException e) {
                  // TODO Auto-generated catch block
                  e.printStackTrace();
            }finally {
                  if(stmt!=null) {//避免空指针异常
                        try {//释放资源
                              stmt.close();
                              } catch (SQLException e) {
                                    // TODO Auto-generated catch block
                                    e.printStackTrace();
                                    }
                        }
                  if(conn!=null) {//避免空指针异常
                        try {//释放资源
                              conn.close();
                        } catch (SQLException e) {
                              // TODO Auto-generated catch block
                              e.printStackTrace();
                              }
                        }
                  }
            }
      }

结果
Image3.png


2)delect 删除(红色的为修改的位置)

package jdbcdemo;
import java.sql.DriverManager;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class jdbcdemo3 {
    public static void main(String[] args) {
        //1.注册驱动
        Statement stmt=null;
        Connection conn=null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            //获取数据库连接对象
            conn=(Connection) DriverManager.getConnection("jdbc:mysql:///b", "root", null);
            //定义sql语句
            String sql="delete from student where id=2";//删除的数据
            //获取执行sql语句的对象statement
            stmt=(Statement) conn.createStatement();
            //执行sql语句
            int count=stmt.executeUpdate(sql);
            if(count>0) {
            System.out.println("删除成功");
            }else {
                System.out.println("删除失败");
            }
        } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
        }catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
            if(stmt!=null) {//避免空指针异常
                try {//释放资源
                    stmt.close();
                    } catch (SQLException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                        }
                }
            if(conn!=null) {//避免空指针异常
                try {//释放资源
                    conn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                    }
                }
            }
        }
    }

结果:
Image4.png


(3)updata修改

package jdbcdemo;
import java.sql.DriverManager;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class jdbcdemo1 {
  public static void main(String[] args){
        //1.导入驱动jar包
        Connection conn = null;
        Statement stat = null;
        try {
              //2.注册驱动
              Class.forName("com.mysql.jdbc.Driver");
              //3.获取数据库连接对象connection
              
              conn = (Connection)  DriverManager.getConnection("jdbc:mysql://localhost:3306/b", "root",  null);
              //4.定义sql
              String sql = "update student set name='123' where  id=1";
              //5.获取执行sql语句的对象statement
              stat=(Statement) conn.createStatement();
              //6.执行sql,接受返回结果
              int count=stat.executeUpdate(sql);
              //7.处理结果
              System.out.println(count);
              
        } catch (ClassNotFoundException e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
        }
        catch (SQLException e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
        }finally {
              /*
               * 避免空指针异常
               */
              if(stat!=null){
                    try {
                          stat.close();
                          } catch (SQLException e) {
                    // TODO Auto-generated catch block
                                e.printStackTrace();
                                }
              }
              if(conn!=null) {
                    try {
                          conn.close();
                          } catch (SQLException e) {
                    // TODO Auto-generated catch block
                                e.printStackTrace();
                                }
                    }
              }
  }
}

(4)查询select

  • a.简单的查询

    • 1.游标向下移动一行
    • 2.判断是否存在数据
    • 3.获取数据
package jdbcdemo;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class jdbdemo4 {
  public static void main(String[] args) {
        //1.注册驱动
        Statement stmt=null;
        Connection conn=null;
        ResultSet re=null;
        try {
              Class.forName("com.mysql.jdbc.Driver");
              //获取数据库连接对象
        conn=(Connection)  DriverManager.getConnection("jdbc:mysql:///b", "root", null);
        //定义sql语句
        String sql="select * from student";
        //获取执行sql语句的对象statement
        stmt=(Statement) conn.createStatement();
        //执行sql语句
        re=stmt.executeQuery(sql);
        re.next();
        int id=re.getInt(1);
        String name=re.getString("name");
        int age=re.getInt("age");
        System.out.println(id+"---"+name+"-------"+age);
        } catch (SQLException e) {
                    // TODO Auto-generated catch block
          e.printStackTrace();
        }catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
        }finally {
                if(stmt!=null) {//避免空指针异常
                           try {//释放资源
                                 stmt.close();
                                 } catch (SQLException e) {
                                       // TODO Auto-generated catch  block
                                       e.printStackTrace();
                                       }
                           }
                     if(conn!=null) {//避免空指针异常
                           try {//释放资源
                                 conn.close();
                           } catch (SQLException e) {
                                 // TODO Auto-generated catch block
                                 e.printStackTrace();
                                 }
                           }
                     if(re!=null) {//避免空指针异常
                           try {//释放资源
                                 re.close();
                           } catch (SQLException e) {
                                 // TODO Auto-generated catch block
                                 e.printStackTrace();
                                 }
                           }
                     }
              }

}

b.升级版,前面的只能输出一个结果,改进为遍历结果输出

    package jdbcdemo;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import com.mysql.jdbc.Connection;
    import com.mysql.jdbc.Statement;
    public class jdbcdemo5 {
          public static void main(String[] args) {
                //1.注册驱动
                Statement statm=null;
                Connection conn=null;
                ResultSet re=null;
                try {
                      Class.forName("com.mysql.jdbc.Driver");
                      //获取数据库连接对象
                conn=(Connection)  DriverManager.getConnection("jdbc:mysql:///b", "root", null);
                //定义sql语句
                String sql="select * from student";
                //获取执行sql语句的对象statement
                statm=(Statement) conn.createStatement();
                //执行sql语句
                re=statm.executeQuery(sql);
                while(re.next()) {
                  //循环判断游标是否是最后一行
                   int id=re.getInt("id");
                     String name=re.getString("name");
                     int age=re.getInt("age");
                     System.out.println(id+"---"+name+"-------"+age);
                }
                
                } catch (SQLException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                }catch (ClassNotFoundException e) {
                      // TODO Auto-generated catch block
                      e.printStackTrace();
                }finally {
                      try {
                            statm.close();
                      } catch (SQLException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                      }
                      try {
                            conn.close();
                      } catch (SQLException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                      }
                      try {
                            re.close();
                      } catch (SQLException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                      }
                }
                
          }
    }
结果:
![Image5.png][6]


c.高级版

 - 定义一个方法,查询emp表的数据将其封装为对象,然后装载集合,返回定义的类:


              
    package jdbcdemo;
    public class emp {
          private int id;
          private String name;
          private int age;
          private int class_num;
          public int getId() {
                return id;
          }
          public void setId(int id) {
                this.id = id;
          }
          public String getName() {
                return name;
          }
          public void setName(String name) {
                this.name = name;
          }
          public int getAge() {
                return age;
          }
          public void setAge(int age) {
                this.age = age;
          }
          public int getClass_num() {
                return class_num;
          }
          public void setClass_num(int class_num) {
                this.class_num = class_num;
          }
          @Override
          public String toString() {
                return "emp [id=" + id + ", name=" + name + ", age=" + age +  ", class_num=" + class_num + ", getClass()="
                            + getClass() + ", hashCode()=" + hashCode() + ",  toString()=" + super.toString() + "]";
          }
    }

调用(代码太长了,省略finally部分)


package jdbcdemo;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class jdbcdemo6 {
    /*
     * 定义一个方法,查询emp表的数据将其封装为对象,然后装载集合,返回
     */
public static void main(String[] args) {
        Connection conn=null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn=(Connection) DriverManager.getConnection("jdbc:mysql:///b", "root", null);
            Statement statm=(Statement) conn.createStatement();
            //执行sql语句
            String sql="select * from student";
            ResultSet re=statm.executeQuery(sql);
            emp emp=null;
            List<emp> list=new ArrayList<emp>();
            while(re.next()) {
                //循环判断游标是否是最后一行,获取数据
                 int id=re.getInt("id");
                 String name=re.getString("name");
                 int age=re.getInt("age");
                 int class_num=re.getInt("class_num");
                 System.out.println(id+"---"+name+"-------"+age);
                 emp=new emp();
                 emp.setAge(age);
                 emp.setId(id);
                 emp.setClass_num(class_num);
                 list.add(emp);
            }
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
        }
    }
}

结果:
Image6.png

声明:Masque's Blog|版权所有,违者必究|如未注明,均为原创|本网站采用BY-NC-SA协议进行授权

转载:转载请注明原文链接 - JDBC学习之statement简单增删改


0.0