New file |
| | |
| | | package com.rongyichuang; |
| | | |
| | | import org.junit.jupiter.api.Test; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.boot.test.context.SpringBootTest; |
| | | import org.springframework.jdbc.core.JdbcTemplate; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | @SpringBootTest |
| | | public class DatabaseConnectionTest { |
| | | |
| | | @Autowired |
| | | private JdbcTemplate jdbcTemplate; |
| | | |
| | | @Test |
| | | public void testDatabaseConnection() { |
| | | try { |
| | | // 检查数据库连接 |
| | | String result = jdbcTemplate.queryForObject("SELECT 1", String.class); |
| | | System.out.println("✅ 数据库连接成功: " + result); |
| | | |
| | | // 检查t_wx_login_record表是否存在 |
| | | try { |
| | | String checkTableSql = "SELECT COUNT(*) FROM information_schema.tables WHERE table_schema = 'ryc' AND table_name = 't_wx_login_record'"; |
| | | Integer tableExists = jdbcTemplate.queryForObject(checkTableSql, Integer.class); |
| | | |
| | | if (tableExists != null && tableExists > 0) { |
| | | System.out.println("✅ t_wx_login_record表存在"); |
| | | |
| | | // 查看表结构 |
| | | String describeTableSql = "DESCRIBE t_wx_login_record"; |
| | | List<Map<String, Object>> columns = jdbcTemplate.queryForList(describeTableSql); |
| | | System.out.println("表结构:"); |
| | | for (Map<String, Object> column : columns) { |
| | | System.out.println("- " + column.get("Field") + ": " + column.get("Type") + |
| | | (column.get("Null").equals("NO") ? " NOT NULL" : " NULL") + |
| | | (column.get("Default") != null ? " DEFAULT " + column.get("Default") : "")); |
| | | } |
| | | |
| | | // 检查表中是否有数据 |
| | | String countSql = "SELECT COUNT(*) FROM t_wx_login_record"; |
| | | Integer recordCount = jdbcTemplate.queryForObject(countSql, Integer.class); |
| | | System.out.println("表中记录数: " + recordCount); |
| | | |
| | | } else { |
| | | System.out.println("❌ t_wx_login_record表不存在"); |
| | | } |
| | | } catch (Exception e) { |
| | | System.out.println("❌ 检查t_wx_login_record表时出错: " + e.getMessage()); |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | | } catch (Exception e) { |
| | | System.out.println("❌ 数据库连接失败: " + e.getMessage()); |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | } |