idea中连接mysql插入成功数据,在navicat中刷新表格没有数据?

比眉伴天荒 2024-03-16 12:32 42阅读 0赞

**目录**

一、出现问题:

二、尝试解决:

三、发现问题:

四、解决方法:

--------------------

## 一、出现问题: ##

在写一个数据库的大作业时，在idea中连接mysql后,测试insert的dao方法,在控制台没有报错,显示题添加数据成功.但是在navicat中刷新表格却没有数据. (本程序为普通的三层架构,手搓JDBC)

![e2267c79764346adbddcfaa1cf2dd587.png][]

![58b913aade9146b5a50722ab659fd7be.png][]

![3e9101cf49d344df8759515697ecb95d.png][]

## 二、尝试解决: ##

1.修改jdbc.properties配置文件.

2.修改数据库配置.

3.检查各处代码.

于是在掰头了一整晚后，第二天用同学的代码却发现可以正常连接，于是在进行一个一个类代码替换后，相同的jdbc.properties，相同的数据库表……终于发现是util包下的代码问题。

## 三、发现问题: ##

1.由于是直接搬运在学习尚硅谷JavaWeb时写的代码,所以在JdbcUtils类中,采用了Filter处理事务的数据库连接方式，原因是原本用在过滤器上的事务的提交和回滚，在没有使用过滤器时就出现了问题。

> connection.close();//关闭事务的自动提交.

事务管理中提交事务的"关闭事务的自动提交"这行代码会使得获取的数据库连接不再自动提交事务.

/**
         * 提交事务,并关闭释放连接.
         */
        public static void commitAndClose() {
            Connection connection = conns.get();
            if (connection != null) {
                try {
                    connection.commit();
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    try {
                        connection.close();//关闭事务的自动提交.
                    } catch (SQLException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
            conns.remove();
        }

JdbcUtils源代码:

package com.my.util;
    
    import com.alibaba.druid.pool.DruidDataSource;
    import com.alibaba.druid.pool.DruidDataSourceFactory;
    
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.util.Properties;
    
    /**
     * @author sihua
     * @create 2022-10-30-20:51
     */
    public class JdbcUtilsFilter {
    
        private static DruidDataSource dataSource;
        private static ThreadLocal<Connection> conns = new ThreadLocal<>();
    
        static {
            try {
                Properties properties = new Properties();
                //读取jdbc.properties属性配置文件.
                InputStream inputStream = JdbcUtilsFilter.class.getClassLoader().
                        getResourceAsStream("jdbc.properties");
                //从流中加载数据
                properties.load(inputStream);
                //创建数据库连接池.
                dataSource = (DruidDataSource) DruidDataSourceFactory.createDataSource(properties);
    
    //            System.out.println(dataSource.getConnection());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        /**
         * 获取数据库连接池中的连接.
         * 如果返回null,说明获取连接失败.
         */
        public static Connection getConnection() {
            Connection conn = conns.get();
            if (conn == null) {
                try {
                    conn = dataSource.getConnection();
                    conns.set(conn);
                    conn.setAutoCommit(false);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            return conn;
        }
    
        /**
         * 提交事务,并关闭释放连接.
         */
        public static void commitAndClose() {
            Connection connection = conns.get();
            if (connection != null) {
                try {
                    connection.commit();
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    try {
                        connection.close();
                    } catch (SQLException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
            conns.remove();
        }
    
    
        /**
         * 关闭连接,放回数据库连接池
         */
    //    public static void close(Connection conn) {
    //        if (conn != null) {
    //            try {
    //                conn.close();
    //            } catch (SQLException e) {
    //                e.printStackTrace();
    //            }
    //        }
    //    }
    
        /**
         * 回滚事务,并关闭释放连接.
         */
        public static void rollBackAndClose() {
            Connection connection = conns.get();
            if (connection != null) {
                try {
                    connection.rollback();
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    try {
                        connection.close();
                    } catch (SQLException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
            conns.remove();
        }
    
    }

## 四、解决方法: ##

将过滤器获取连接方法去掉.

### （谨以此篇博客给我长长记性。） ###

[e2267c79764346adbddcfaa1cf2dd587.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/5f873b9c3953431d9318924b5fc664ae.png
[58b913aade9146b5a50722ab659fd7be.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/5c4004c8a6a24d0285f8b9f1ff6d80fa.png
[3e9101cf49d344df8759515697ecb95d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/16/51688a42e0034d73849e396f24c09f71.png