MySQL之JDBC编程增删改查

左手的ㄟ右手 2024-03-16 20:41 30阅读 0赞

### MySQL之JDBC ###

#### 一、JDBC是什么 ####

Java DatabaseConnectivity （java语言连接数据库）

#### 二、JDBC的本质 ####

JDBC是SUN公司制定的一套接口(interface)。

接口都有调用者和实现者。

面向接口调用、面向接口写实现类，这都属于面向接口编程。

#### 三、为什么要面向接口编程 ####

解耦合：降低程序的耦合度，提高程序的扩展力。解耦合可以理解为淘宝的两个页面，你在将商品加入订单的时候出现错误，但是不会影响你在主页浏览商品，就是两个模块之间的联系不那么紧密，说明两个模块内聚就高。

![e153375dc46f7af21b37edbf51566d0f.png][]

### 四、为什么SUN制定一套JDBC接口 ###

因为每一个数据库产品都有自己独特的实现原理

### 五、JDBC编程六步 ###

1、注册驱动（告诉Java程序要连接哪个品牌的数据库）

2、获取连接（表示JVM的进程和数据库进程之间的通道打开了，这属于进程之间的通信，使用完后记得关闭通道）。

3、获取数据库操作对象（专门执行sql语句的对象）

4、执行SQL语句（DQL，DML...）

5、处理查询结果集 （只有当第四步执行的是select语句的时候，才有本步）

6、释放资源（使用完资源后一定要关闭资源，Java和数据库之间属于进程间的通信，开启之后一定要记得关闭）

### 六、IDEA编写JDBC连接MySQL ###

#### 第一种方法： ####

1.进入mysql官网

2.点击下载downloads

![168a7e1cfd9530ee7f7d2077e9960b31.png][]

3.点击下载社区版\[MySQL Community (GPL) Downloads »\]

![2ee1a7e195defdbccf7fc6cd370a144a.png][]

4.选择jdbc连接器Connector/J

![2dc7a148c8d7c536635c77317f242d87.png][]

5.选择Archives下载5.1版本的（支持的数据库版本更多）

![f4e3b29297332ffb718c09316e5d6a72.png][]

两个都可以下载，自己选一个

![5d77b0628cba3317527a7c4f02122e16.png][]

6.解压后拿到一个mysql-connector-java-5.1.49.jar的包

7.在idea创建一个工程，点击file

![c013a2e98911e46fde7c0a4dcdcd3fc7.png][]

![42148c573dbca28ee9a3afcead829029.png][]

8.点击Java，选择你解压后的jar包，不要选择带bin的，是二进制的意思。点击ok就行。

#### 第二种方法 ####

> 先检查jar包位置：在目录里新建一个文件夹 libs，把jar包复制进去

![b34cee945c8263ffa352550c8e31cdd5.png][]

> 然后右键选择新建文件夹libs转成library

![1fc7b0efbde85196376fb21a6b212eff.png][]

> 然后就可以写代码啦！

![99b4a89f553a354288795d129751cdb5.png][]

###  ###

### 七、jdbc连接mysql程序编写 ###

7.1 第一种注册驱动方式

public class JDBCTest1 {
        private static Statement stat;
        private static Connection conn;
        public static void main(String[] args) {
            //1.注册驱动
            try {
                DriverManager.registerDriver(new Driver());
                //2.获取连接
    //            DriverManager.getConnection("jdbc:mysql://192.168.137.150:3306?" +
    //                    "useUnicode=true&characterEncoding=utf8&useSSL=false","root","123456");
                /*
                url: 统一资源定位系统
                 *          http/https: 通过网络请求去访问网络上的资源
                 *          jdbc:mysql: 是驱动提供的请求头
                 *          请求的地址: 指定mysql的服务器地址：192.168.254.150
                 *          端口号: 3306
                 *          useUnicode=true&characterCharset=utf8
                 */
                String url ="jdbc:mysql://192.168.137.150:3306/bigdata19?useUnicode=true&characterEncoding=utf8&useSSL=false";
                String user = "root";
                String password = "123456";
                conn = DriverManager.getConnection(url, user, password);
                System.out.println("与mysql连接成功"+conn);
                //获取数据库操作对象
                stat = conn.createStatement();
                //DQL
                //ResultSet executeQuery(String sql)
                //执行给定的SQL语句，该语句返回单个 ResultSet对象。
    
                //DML(数据库操作语言，增删改)
                //int executeUpdate(String sql)
                //执行给定的SQL语句，这可能是 INSERT ， UPDATE ，或 DELETE语句，或者不返回任何内容，如SQL DDL语句的SQL语句。
                // 方法的返回值指的是受影响的行数： Affected rows: 1
                int count = stat.executeUpdate("insert into dept(deptno,dname,loc) values(50,'教学部','合肥')");
                System.out.println(count==1?"数据保存成功":"数据保存失败");
    
            } catch (SQLException e) {
                e.printStackTrace();
            }finally {
                //释放资源
                if (stat!=null){
                    try {
                        stat.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
                if (conn!=null){
                    try {
                        conn.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }

![77b5883fca3f7098a053b2214bc0b655.png][]

7.2第二种注册驱动方式

public class JDBCTest2 {
        public static void main(String[] args) {
            //注册驱动的第二种方式
            //注册驱动底层实际上就是用驱动包中对应的类，而驱动包中的类都是class后缀的编译好的文件
            //       要想直接使用编译好的类，使用反射来实现。
            //       想一想，反射是如何获取一个类的class文件对象呢？3种方式
            //       1、getClass
            //       2、.class
            //       3、Class.forName()
    
            Connection conn = null;
            Statement stat = null;
    
            try {
                //加载驱动
                Class.forName("com.mysql.jdbc.Driver");
    
                //创建与数据库连接的对象
                String url = "jdbc:mysql://192.168.137.150:3306/bigdata19?useUnicode=true&characterEncoding=utf8&useSSL=false";
                String user="root";
                String password="123456";
                conn = DriverManager.getConnection(url, user, password);
    
                //获取与操作数据库的对象
                stat = conn.createStatement();
    
                //编写sql语句并执行
                //增
                String sql="insert into dept(deptno,dname,loc) values(60,'行政部','合肥')";
                int count2 = stat.executeUpdate(sql);
                System.out.println(count2==1?"数据增加成功":"数据增加失败");
    
                //改
                String sql1 ="update dept set dname='研发部'where deptno=60";
                int count3 = stat.executeUpdate(sql1);
                System.out.println(count3==1?"数据修改成功":"数据修改失败");
    
                //删
                String sql2 = "delete from dept where deptno=50";
                int count4 = stat.executeUpdate(sql2);
                System.out.println(count4==1?"数据删除成功":"数据删除失败");
    
    
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
            }finally{
                if (stat!=null){
                    try {
                        stat.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
                if (conn!=null){
                    try {
                        conn.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
            }
    
        }
    }

![3234e214057bd036125742fafe612984.png][]

![7c37bb90b64e609ac321d297174a26ec.png][]

7.3将连接数据库的所有信息配置到配置文件中

public class JDBCTest3 {
        /*
        使用配置文件将连接数据库的相关参数进行保存，然后在代码中使用
            使用jdk自身提供的Properties类来加载配置文件
         */
        public static void main(String[] args) throws IOException, ClassNotFoundException, SQLException {
            //使用无参构造方法创建Properties类的对象
            Properties prop = new Properties();
    
            //使用字符流读取配置文件
            BufferedReader br = new BufferedReader(new FileReader("F:\\software\\IdeaProjects\\bigdata19_mysql\\resource\\jdbc.properties"));
    
            prop.load(br);
            String driver = prop.getProperty("driver");
            String url = prop.getProperty("url");
            String user = prop.getProperty("user");
            String password = prop.getProperty("password");
    
            //加载驱动
            Class.forName(driver);
    
            //获取连接对象
            Connection conn = DriverManager.getConnection(url, user, password);
    
            //获取数据库操作对象
            Statement stat = conn.createStatement();
    
            //执行sql语句
            int count = stat.executeUpdate("insert into dept(deptno,dname,loc) values(70,'教学部','合肥')");
            System.out.println(count==1?"数据插入成功":"数据插入失败");
    
            //释放资源
            if (stat!=null){
                stat.close();
            }
            if (conn!=null){
                conn.close();
            }
    
        }
    }

![d9435114acaf14bc15e520113f5c64b3.png][]

![f017d2a5dd4cee2ddb22bbfddb3c252a.png][]

7.4处理查询

工具类封装

public class MySqlTool {
        /*
        工具类
        1.不能让外界实例化（构造方法私有化）
        2.方法必须是静态
    
         */
        private static Connection conn;
        private MySqlTool(){}
    
        public static Connection init(){
            try {
                Properties prop = new Properties();
    
                //使用字符流读取配置文件
                BufferedReader br = new BufferedReader(new FileReader("F:\\software\\IdeaProjects\\bigdata19_mysql\\resource\\jdbc.properties"));
    
                prop.load(br);
                String driver = prop.getProperty("driver");
                String url = prop.getProperty("url");
                String user = prop.getProperty("user");
                String password = prop.getProperty("password");
    
                //加载驱动
                Class.forName(driver);
    
                //获取连接对象
                conn = DriverManager.getConnection(url, user, password);
    
    
            }catch (Exception e){
                e.printStackTrace();
            }
            return conn;
        }
    
    }

public class JDBCTest4 {
        public static void main(String[] args) throws SQLException {
            //通过工具类获取数据库连接对象
            Connection conn = MySqlTool.init();
            //获取数据库操作对象
            Statement stat = conn.createStatement();
    
            //执行sql语句
            ResultSet result = stat.executeQuery("select deptno,dname,loc from dept");
            //处理查询结果集
            boolean b = result.next();
            //将光标从当前位置向前移动一行。
            //如果光标移动的位置有值，这里的返回值是true
    //        if (b){
    //            //获取一行中每一列的数值，第一种方式
    //            String deptno = result.getString(1);
    //            String dname = result.getString(2);
    //            String loc = result.getString(3);
    //            System.out.println("部门编号："+deptno+",部门名称："+dname+",部门地址："+loc);
    //
    //        }
            //正常情况下，一张结果表的行数我们不确定，但是我们知道，当next的结果是false的时候，表示读取到末尾
            while(result.next()){
                //获取一行中每一列的数值，第一种方式
    //            String deptno = result.getString(1);
    //            String dname = result.getString(2);
    //            String loc = result.getString(3);
    //            System.out.println("部门编号："+deptno+",部门名称："+dname+",部门地址："+loc);
                //第二种方式，根据列名获取对应的列值
                //注意事项：当查询sql语句中存在起别名的情况时，通过列名获取列值的时候，使用名字是别名
                String deptno = result.getString("deptno");
                String dname = result.getString("dname");
                String loc = result.getString("loc");
                System.out.println("部门编号："+deptno+",部门名称："+dname+",部门地址："+loc);
            }
            //注意事项2：同一个结果resultSet对象，只能遍历一次
            System.out.println("=========================");
            //再次遍历，结果不显示
            while(result.next()){
                //获取一行中每一列的数值，第一种方式
    //            String deptno = result.getString(1);
    //            String dname = result.getString(2);
    //            String loc = result.getString(3);
    //            System.out.println("部门编号："+deptno+",部门名称："+dname+",部门地址："+loc);
                //第二种方式，根据列名获取对应的列值
                //注意事项：当查询sql语句中存在起别名的情况时，通过列名获取列值的时候，使用名字是别名
                String deptno = result.getString("deptno");
                String dname = result.getString("dname");
                String loc = result.getString("loc");
                System.out.println("部门编号："+deptno+",部门名称："+dname+",部门地址："+loc);
            }
    
    
    
            //释放资源
            if (stat!=null){
                stat.close();
            }
            if (conn!=null){
                conn.close();
            }
    
        }
    }

![6d1242cde17f30d89fa83e66ad2f167d.png][]

7.5登录注册案例

public class JDBCTest5 {
        public static void main(String[] args) throws SQLException {
            /*
            使用jdbc模拟登录注册案例
            1、注册账号：往数据库插入一条数据
            2、登录账号：查询数据库
    
             */
            //1.建表user
            //创建键盘录入对象
            System.out.println("欢迎来到提瓦特大陆，准备好开始冒险了吗？");
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入旅行者的名字：");
            String username = scanner.next();
            System.out.println("请输入密码：");
            String password = scanner.next();
    
            //创建数据库驱动
    //        try {
    //            DriverManager.registerDriver(new Driver());
    //        } catch (SQLException e) {
    //            e.printStackTrace();
    //        }
    //
    //        Connection conn = DriverManager.getConnection();
            //直接采用工具类获取与数据库的连接对象
            Connection conn = MySqlTool.init();
            //获取数据库操作对象
            Statement stat = conn.createStatement();
    
            //编写sql语句
            String sql= "select username,password from user where username='"+username+"'and password='"+password+"'";
            //执行sql语句
            ResultSet rs = stat.executeQuery(sql);
            //处理查询结果集
            boolean b = rs.next();
            if (b){
                System.out.println("旅行者"+username+"，欢迎来到提瓦特大陆！");
            }else{
                System.out.println("您还未注册成为旅行者,是否注册（Y/N）");
                String choice = scanner.next();
                if ("Y".equals(choice)){
                    while (true){
                        System.out.println("请输入旅行者的名字：");
                        String new_username = scanner.next();
                        System.out.println("请输入密码：");
                        String new_password = scanner.next();
                        System.out.println("请确认密码：");
                        String again_password = scanner.next();
                        if (again_password.equals(new_password)) {
                            UUID uuid = UUID.randomUUID();//随机生成uuid
                            String new_uuid = uuid + "-" + System.currentTimeMillis();
    
                            String sql2 = "insert into user(uid,username,password) values('" + new_uuid + "','" + new_username +"','"+ new_password +"')";
                            int count = stat.executeUpdate(sql2);
                            if (count == 1) {
                                System.out.println("注册成功");
                            } else {
                                System.out.println("注册失败");
                            }
                            break;
                        }else {
                            System.out.println("两次密码输入不一致，请重新输入：");
    
                        }
                    }
                }
            }
            stat.close();
            conn.close();
    
        }
    }

![89b86978a7bb08e8f5a22cf51da352f1.png][]

7.6解决sql注入问题

public class JDBCTest6 {
        public static void main(String[] args) throws SQLException {
            /*
            我们写完程序后发现，当我们将密码输入成1234' or '1'='1这个样子的时候，发现登录成功
            原因：sql在编译的时候，会将我们输入的内容存在关键字or,会把or当作sql语法关键字进行执行
            如何解决呢？
                这样的问题，称之为sql注入的问题
                解决的思路就是在sql编译完后再传入数据
    
           获取数据库操作对象另外一种方式，预编译的方式
             */
            /*
            使用jdbc模拟登录注册案例
            1、注册账号：往数据库插入一条数据
            2、登录账号：查询数据库
    
             */
            //1.建表user
            //创建键盘录入对象
            System.out.println("欢迎来到提瓦特大陆，准备好开始冒险了吗？");
            Scanner scanner = new Scanner(System.in);
            System.out.println("请输入旅行者的名字：");
            String username = scanner.nextLine();
            System.out.println("请输入密码：");
            String password = scanner.nextLine();
    
            //创建数据库驱动
    //        try {
    //            DriverManager.registerDriver(new Driver());
    //        } catch (SQLException e) {
    //            e.printStackTrace();
    //        }
    //
    //        Connection conn = DriverManager.getConnection();
            //直接采用工具类获取与数据库的连接对象
            Connection conn = MySqlTool.init();
    //        //获取数据库操作对象
    //        Statement stat = conn.createStatement();
    //
    //        //编写sql语句
    //        String sql= "select username,password from user where username='"+username+"'and password='"+password+"'";
    //        //执行sql语句
    //        ResultSet rs = stat.executeQuery(sql);
    
            //这里的问号相当于一个占位符，为了后面传值
            String sql = "select username,password from user where username=? and password=?";
            //创建预编译数据库操作对象
            PreparedStatement pps = conn.prepareStatement(sql);
            //将sql中的占位符附上值
            //第一个参数表示给第几个问号传值，第二个参数表示具体的值，序号从1开始
            pps.setString(1,username);
            pps.setString(2,password);
    
            //执行sql语句
            ResultSet rs = pps.executeQuery();
    
            //处理查询结果集
            boolean b = rs.next();
            if (b){
                System.out.println("旅行者"+username+"，欢迎来到提瓦特大陆！");
            }else{
                System.out.println("您还未注册成为旅行者,是否注册（Y/N）");
                String choice = scanner.next();
                if ("Y".equals(choice)){
                    while (true){
                        System.out.println("请输入旅行者的名字：");
                        String new_username = scanner.next();
                        System.out.println("请输入密码：");
                        String new_password = scanner.next();
                        System.out.println("请确认密码：");
                        String again_password = scanner.next();
                        if (again_password.equals(new_password)) {
                            UUID uuid = UUID.randomUUID();//随机生成uuid
                            String new_uuid = uuid + "-" + System.currentTimeMillis();
    
                            String sql2 = "insert into user(uid,username,password) values('" + new_uuid + "','" + new_username +"','"+ new_password +"')";
                            int count = pps.executeUpdate(sql2);
                            if (count == 1) {
                                System.out.println("注册成功");
                            } else {
                                System.out.println("注册失败");
                            }
                            break;
                        }else {
                            System.out.println("两次密码输入不一致，请重新输入：");
    
                        }
                    }
                }
            }
            pps.close();
            conn.close();
    
        }
    }

![c3ae4003bd05320eb1c6a1238795de0a.png][]

7.7JDBC实现模糊查询

public class JDBCTest7 {
        public static void main(String[] args) throws SQLException {
            //获取数据库连接对象
            Connection conn = MySqlTool.init();
            //获取预编译数据库操作对象
            String sql="select uid,username,password from user where username like ?";
            PreparedStatement pps = conn.prepareStatement(sql);
            pps.setString(1,"%bfy%");
            //执行sql语句
            ResultSet rs = pps.executeQuery();
            //处理查询结果集
            while (rs.next()){
                String uid=rs.getString(1);
                String username=rs.getString(2);
                String password=rs.getString(3);
                System.out.println(uid+','+username+','+password);
            }
    
            pps.close();
            conn.close();
        }
    }

![c1e45f87ae8e4f19b54ddb64d3e13b67.png][]

[e153375dc46f7af21b37edbf51566d0f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/87c01fbafa4e4273b2693e2f6558b84b.png
[168a7e1cfd9530ee7f7d2077e9960b31.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/0a9e04fc7a8043b09945c364569f748b.png
[2ee1a7e195defdbccf7fc6cd370a144a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/41365d175e1a4779843865ae7ed5fd58.png
[2dc7a148c8d7c536635c77317f242d87.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/e7fd16b347144f558a9c6a5a4aab1576.png
[f4e3b29297332ffb718c09316e5d6a72.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/1ed58c2c3f7344278850b5cfc68577df.png
[5d77b0628cba3317527a7c4f02122e16.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/d6d1955729e94a35b8b73fdaa18079c0.png
[c013a2e98911e46fde7c0a4dcdcd3fc7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/007b7a670967419e9b8ba17faf16d1fb.png
[42148c573dbca28ee9a3afcead829029.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/eca09fec43c145c695c4399472b66006.png
[b34cee945c8263ffa352550c8e31cdd5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/e6308baf30264345bed96888b3e54344.png
[1fc7b0efbde85196376fb21a6b212eff.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/3150e10658fb4f198c598e7431958946.png
[99b4a89f553a354288795d129751cdb5.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/2ec3506853464a0e8ff8030d6b40a5cf.png
[77b5883fca3f7098a053b2214bc0b655.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/14bd9f08e0f74706a0f1d54362a0bc6d.png
[3234e214057bd036125742fafe612984.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/a0772895a9ea4591ac20f12e5456a13d.png
[7c37bb90b64e609ac321d297174a26ec.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/b2a37d2b6a31468699214ccbdfca0b11.png
[d9435114acaf14bc15e520113f5c64b3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/8c26840abb454179a255924b51846001.png
[f017d2a5dd4cee2ddb22bbfddb3c252a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/5abf00a5a0e84991bec56888d422d4b3.png
[6d1242cde17f30d89fa83e66ad2f167d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/f49acaa58af541eb8826f9e4f2b8dd9d.png
[89b86978a7bb08e8f5a22cf51da352f1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/6e77de5d687b4a8892ec31c2e7c02b76.png
[c3ae4003bd05320eb1c6a1238795de0a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/b8c7ba2d6bf048a0be745eb3b4024245.png
[c1e45f87ae8e4f19b54ddb64d3e13b67.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/15/451cd08758c340a8afac152c84c9b58e.png