diff --git "a/04 \346\235\216\346\230\216\345\201\245/20230516 JDBC\344\275\234\344\270\232.md" "b/04 \346\235\216\346\230\216\345\201\245/20230516 JDBC\344\275\234\344\270\232.md" new file mode 100644 index 0000000000000000000000000000000000000000..98b0053d6b44178c26b0275d7629e3320510684d --- /dev/null +++ "b/04 \346\235\216\346\230\216\345\201\245/20230516 JDBC\344\275\234\344\270\232.md" @@ -0,0 +1,242 @@ +### Test类(查) + +~~~ java +import java.sql.*; + +public class Test { + public static void main(String[] args) { + //1.注册驱动 + ResultSet rst = null; + Statement smt = null; + Connection conn = null; + try { + Class.forName("com.mysql.jdbc.Driver"); + + //2.获取连接对象 + String url ="jdbc:mysql://localhost:3306/student_db?useSSL=false&useUnicode=true&characterEncoding=utf8"; + String username ="root"; + String password = "root"; + + conn = DriverManager.getConnection(url, username, password); + + //3.编写SQL语句 + String sql = "select * from student"; + + //4.获取执行SQL的对象 + smt = conn.createStatement(); + + //5.用smt执行SQL + rst = smt.executeQuery(sql); + + //处理返回结果(遍历结果) + while(rst.next()){ + System.out.println(rst.getInt("id") + + "\t" + rst.getString("name") + + "\t " + rst.getString("sex")); + } + } catch (ClassNotFoundException e) { + System.out.println("驱动包导入失败!"); + } catch (SQLException e) { +// e.printStackTrace(); + System.out.println("sql语句出错!"); + } finally { + //7.释放资源 + try { + if(rst!=null){ + rst.close(); + } + if(smt!=null){ + smt.close(); + } + if(conn!=null){ + conn.close(); + } + } catch (SQLException e) { + System.out.println("释放资源出错"); + } + } + + } +} +~~~ + +### Insert类(增) + +~~~ java +import java.sql.*; + +public class Insert { + public static void main(String[] args) { + //1.注册驱动 + try { + Class.forName("com.mysql.jdbc.Driver"); + + //2.获取连接的对象 + String url = "jdbc:mysql://localhost:3306/student_db?useSSL=false&useUnicode=true&characterEncoding=utf8"; + String username = "root"; + String password = "root"; + + Connection conn = DriverManager.getConnection(url, username, password); + + //3.编写SQL语句 + String sql = "insert into student values(4,'小李','男')"; + + //4.获取执行SQL的对象 + Statement smt = conn.createStatement(); + + //5.用smt执行SQL + int i = smt.executeUpdate(sql); + + //6.处理返回结果(遍历结果) + if(i!=0){ + System.out.println("添加成功!"); + System.out.println("添加了"+i+"条数据"); + }else{ + System.out.println("添加了"+i+"条数据"); + System.out.println("添加失败!"); + } + //7.释放资源 + smt.close(); + conn.close(); + + } catch (ClassNotFoundException e) { + System.out.println("驱动包导入失败!"); + } catch (SQLException e) { +// e.printStackTrace(); + System.out.println("sql语句出错!"); + } + + } +} +~~~ + +### Delete类(删) + +~~~ java +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.SQLException; +import java.sql.Statement; + +public class Delete { + public static void main(String[] args) { + //1.注册驱动 + try { + Class.forName("com.mysql.jdbc.Driver"); + + //2.获取连接的对象 + String url = "jdbc:mysql://localhost:3306/student_db?useSSL=false&useUnicode=true&characterEncoding=utf8"; + String username = "root"; + String password = "root"; + + Connection conn = DriverManager.getConnection(url, username, password); + + //3.编写SQL语句 + String sql = "delete from student where id=4"; + + //4.获取执行SQL的对象 + Statement smt = conn.createStatement(); + + //5.用smt执行SQL + int i = smt.executeUpdate(sql); + + //6.处理返回结果(遍历结果) + if(i!=0){ + System.out.println("删除成功!"); + System.out.println("删除了"+i+"条数据"); + }else{ + System.out.println("删除了"+i+"条数据"); + System.out.println("删除失败!"); + } + //7.释放资源 + smt.close(); + conn.close(); + + } catch (ClassNotFoundException e) { + System.out.println("驱动包导入失败!"); + } catch (SQLException e) { +// e.printStackTrace(); + System.out.println("sql语句出错!"); + } + } +} +~~~ + +### Update类(改) + +~~~ java +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.SQLException; +import java.sql.Statement; +import java.util.Scanner; + +public class Update { + public static void main(String[] args) { + + + //1.注册驱动 + try { + Class.forName("com.mysql.jdbc.Driver"); + + //2.获取连接的对象 + String url = "jdbc:mysql://localhost:3306/student_db?useSSL=false&useUnicode=true&characterEncoding=utf8"; + String username = "root"; + String password = "root"; + + + Connection conn = DriverManager.getConnection(url, username, password); + + //3.编写SQL语句 + String sql = "update student set sex='女' where id=3"; + + //4.获取执行SQL的对象 + Statement smt = conn.createStatement(); + + //5.用smt执行SQL + int i = smt.executeUpdate(sql); + + //6.处理返回结果(遍历结果) + if (i != 0) { + System.out.println("修改成功!"); + System.out.println("修改了" + i + "条数据"); + } else { + System.out.println("修改了" + i + "条数据"); + System.out.println("修改失败!"); + } + //7.释放资源 + smt.close(); + conn.close(); + + } catch (ClassNotFoundException e) { + System.out.println("驱动包导入失败!"); + } catch (SQLException e) { +// e.printStackTrace(); + System.out.println("sql语句出错!"); + } + } +} +~~~ + + + +Mysql + +~~~ mysql +create database student_db charset utf8; +use student_db; + +create table student( + id int, + name varchar(5), + sex varchar(1) +); + +insert into student values +(1,"张三","男"), +(2,"李四","女"), +(3,"王五","男"); + + +~~~ +