【项目管理】一款仿Navicat的Swing数据库管理工具

痛定思痛。 2024-04-07 14:43 72阅读 0赞

#### 【项目管理】一款仿Navicat的Swing数据库管理工具 ####

*  1.项目简介
 *  2.项目主体
 *   *  2.1 关于页面
     *  2.2 新建连接
     *  2.3 连接节点右键菜单
     *  2.4 新建数据库
     *  2.5 查询数据库中的表、视图、存储过程
     *  2.6 表单数据的查看
     *  2.7 选项卡的关闭
     *  2.8 选项卡的右键功能
     *  2.9 查询功能实现
 *  3.源码地址

> System : Windows 10  
> Intellij IDEA : Ultimate 2020.3.4  
> Java : 1.8.0\_333  
> MySQL : 8.0.30

## 1.项目简介 ##

该项目是一款使用 Java Swing 技术制作的数据库管理工具，具有简单连接数据库查看数据功能，仅做学习使用。该项目使用了一款国人开发的 LAF(LookAndFeel) beautyeye，感觉蛮好看的。

## 2.项目主体 ##

### 2.1 关于页面 ###

主要代码

/**
     * @ClassName AboutDialog
     * @Description 关于页面
     * @Author Li
     * @Date 2022/8/15 13:00
     * @ModifyDate 2022/8/15 13:00
     * @Version 1.0
     */
    public class AboutDialog extends JDialog {
        
        private MainFrame mainFrame; // 主界面对象
    
        public AboutDialog(MainFrame mainFrame) {
        
            this.mainFrame = mainFrame;
            this.setSize(new Dimension(600, 400)); // 设置大小
            this.setTitle("关于"); // 设置标题
            this.setUndecorated(true); // 禁用对话框的装饰
    
            JPanel contentPane = new JPanel();
            contentPane.setBackground(new Color(60, 60, 60));
            contentPane.setBorder(BorderFactory.createEtchedBorder());
            contentPane.setLayout(new GridBagLayout());
    
            JPanel panel = new JPanel();
            panel.setBackground(new Color(60, 60, 60));
            panel.setLayout(new GridLayout(2, 1, 0, 20));
            // 上半部分 LOGO + 名称
            JPanel topPanel = new JPanel();
            topPanel.setBackground(new Color(60, 60, 60));
            topPanel.setLayout(new FlowLayout());
            JLabel logoLabel = new JLabel(new ImageIcon(ImageUtil.LOGO_IMAGE.getScaledInstance(40, 40, Image.SCALE_SMOOTH)));
            JLabel nameLabel = new JLabel("DBClient");
            nameLabel.setFont(new Font("微软雅黑", 1, 48));
            nameLabel.setForeground(Color.WHITE);
            topPanel.add(logoLabel);
            topPanel.add(nameLabel);
            // 下半部分，作者
            JPanel bottomPanel = new JPanel();
            bottomPanel.setBackground(new Color(60, 60, 60));
            JLabel authorLabel = new JLabel("Author : lijinjiang01");
            authorLabel.setFont(new Font("微软雅黑", 1, 25));
            authorLabel.setForeground(Color.WHITE);
            bottomPanel.add(authorLabel);
    
            panel.add(topPanel);
            panel.add(bottomPanel);
            contentPane.add(panel);
    
            this.setContentPane(contentPane);
            this.setAlwaysOnTop(true); // 设置永远显示在最上面
            this.addWindowFocusListener(new WindowFocusListener() {
        
                @Override
                public void windowGainedFocus(WindowEvent e) {
        
    
                }
    
                @Override
                public void windowLostFocus(WindowEvent e) {
        
                    // 当点击 JDialog 外的地方时，则关闭 JDialog 窗口
                    AboutDialog.this.dispose();
                }
            });
            this.setResizable(false); // 不可变化大小
            this.setLocationRelativeTo(this.mainFrame); // 相对主界面居中
            this.setVisible(true); // 设置可见
        }
    }

效果演示  
![849bed349c429b89fb1b153e0c450171.png][]

### 2.2 新建连接 ###

主要代码

// 新建时的确定按钮：保存连接信息
    confirmBtn.addActionListener(e -> {
        
        // 得到用户输入的信息，并返回一个ServerConnection
        ServerConnection sc = getCurrentSC();
        if (!dataValidate(sc)) {
        
            JOptionPane.showMessageDialog(SCDialog.this, "配置信息不能为空，请补充完整！", "错误", JOptionPane.ERROR_MESSAGE);
            return;
        }
        // 判断连接名是否重复
        if (this.ctx.getSC(sc.getName()) != null) {
        
            JOptionPane.showMessageDialog(SCDialog.this, "已存在命名为" + sc.getName() + "的连接！", "错误", JOptionPane.ERROR_MESSAGE);
            return;
        }
        // 直接保存，不需要创建任何连接
        this.ctx.addSC(sc);
        // 保存到属性文件
        this.ctx.getPropertiesHandler().saveSC(sc);
        // 刷新树节点中的连接
        this.mainFrame.getLeftPane().addSCNode(sc);
        this.dispose();
    });

效果演示  
![74670b07e99ca3cd6fb5236d7deca6c9.gif][]

### 2.3 连接节点右键菜单 ###

效果演示  
![8224c053be0f41bcc6079418c42528ed.gif][]

### 2.4 新建数据库 ###

主要代码

/**
     * 创建一个数据库，并返回其排序位置的索引
     * @param dialog
     * @param database
     * @return
     */
    public int createDatabase(DBDialog dialog, Database database) {
        
        if (database != null) {
        
            String name = database.getDbName();
            if (name != null && !"".equalsIgnoreCase(name)) {
        
                String sql = "CREATE DATABASE " + name + " DEFAULT CHARACTER SET " + database.getCharset() + " DEFAULT COLLATE " + database.getCollation();
                try {
        
                    Statement stmt = getStatement();
                    stmt.executeUpdate(sql);
                    dialog.dispose();
                    List<Database> dbs = getDatabases();
                    for (int i = 0; i < dbs.size(); i++) {
        
                        if (name.equalsIgnoreCase(dbs.get(i).getDbName())) {
        
                            return i;
                        }
                    }
                    return -1;
                } catch (Exception e) {
        
                    JOptionPane.showMessageDialog(dialog, e.getMessage(), "错误", JOptionPane.ERROR_MESSAGE);
                    return -1;
                }
            } else {
        
                return -1;
            }
        } else {
        
            return -1;
        }
    }

效果演示  
![d2da6c14bac01ae6061935ee33af3921.gif][]

### 2.5 查询数据库中的表、视图、存储过程 ###

主要代码

// 获取该数据库下的所有的表单
    public List<Table> getTables() {
        
        List<Table> list = new ArrayList<>();
        // 去系统表information_schema查询
        String sql = "SELECT TABLE_NAME FROM information_schema.TABLES sc WHERE (sc.TABLE_TYPE='" + MySQLUtil.TABLE_TYPE
                + "' OR sc.TABLE_TYPE='" + MySQLUtil.SYSTEM_VIEW_TYPE + "') AND sc.TABLE_SCHEMA='" + this.dbName
                + "' ORDER BY TABLE_NAME";
        try {
        
            // 获得本连接下面的所有数据库
            Statement stmt = getStatement();
            ResultSet rs = stmt.executeQuery(sql);
            while (rs.next()) {
        
                String tableName = rs.getString("TABLE_NAME");
                Table table = new Table(this, tableName);
                list.add(table);
            }
            rs.close();
            return list;
        } catch (Exception e) {
        
            return list;
        }
    }
    
    // 获取该数据库下的所有的视图
    public List<View> getViews() {
        
        List<View> list = new ArrayList<>();
        // 到 information_schema 数据库中的 VIEWS 表查询
        String sql = "SELECT * FROM information_schema.VIEWS sc WHERE sc.TABLE_SCHEMA='" + this.dbName
                + "' ORDER BY TABLE_NAME";
        try {
        
            // 获得本连接下面的所有数据库
            Statement stmt = getStatement();
            ResultSet rs = stmt.executeQuery(sql);
            while (rs.next()) {
        
                String viewName = rs.getString("TABLE_NAME");
                View view = new View(this, viewName);
                list.add(view);
            }
            rs.close();
            return list;
        } catch (Exception e) {
        
            return list;
        }
    }
    
    // 获取所有的存储过程
    public List<Procedure> getProcedures() {
        
        List<Procedure> list = new ArrayList<>();
        // 去系统表information_schema查询
        String sql = "SELECT * FROM information_schema.Routines WHERE ROUTINE_SCHEMA='" + dbName
                + "' AND ROUTINE_TYPE='" + MySQLUtil.PROCEDURE_TYPE + "' ORDER BY ROUTINE_NAME";
        try {
        
            // 获得一个连接下面的所有数据库
            Statement stmt = getStatement();
            ResultSet rs = stmt.executeQuery(sql);
            while (rs.next()) {
        
                String procedureName = rs.getString("ROUTINE_NAME");
                Procedure procedure = new Procedure(this, procedureName);
                list.add(procedure);
            }
            rs.close();
            return list;
        } catch (Exception e) {
        
            return list;
        }
    }

效果演示  
![e81cb624a4ca8265ca1597f64182eaaf.gif][]

### 2.6 表单数据的查看 ###

![e90e677794da24f431ba00c1ca752780.gif][]

### 2.7 选项卡的关闭 ###

主要代码

// 显示表单数据
    public void showTableData(Table table) {
        
        if (table != null) {
        
            Database db = table.getDatabase();
            String title = table.getTableName() + "@" + db.getDbName() + "  ";
            JPanel tabComponent = new JPanel();
            tabComponent.setOpaque(false); // 设置背景透明
            tabComponent.setLayout(new BorderLayout());
            JLabel titleLabel = new JLabel(title);
            tabComponent.add(titleLabel, BorderLayout.WEST);
            JLabel closeLabel = new JLabel();
            closeLabel.setIcon(ImageUtil.CLOSE_ICON);
            tabComponent.add(closeLabel, BorderLayout.EAST);
    
            int count = this.getTabCount();
            for (int i = 0; i < count; i++) {
        
                String s = this.getTitleAt(i);
                if (s.equalsIgnoreCase(title)) {
        
                    this.setSelectedIndex(i);
                    return;
                }
            }
            TableDataPane dataPanel = new TableDataPane(table);
            this.insertTab(title, null, dataPanel, null, count); // 添加一页显示对应表单数据
            this.setTabComponentAt(count, tabComponent);
            // 关闭的图片添加监听，点击关闭
            closeLabel.addMouseListener(new MouseAdapter() {
        
                @Override
                public void mousePressed(MouseEvent e) {
        
                    if (e.getModifiers() == MouseEvent.BUTTON1_MASK) {
        
                        JLabel source = (JLabel) e.getSource();
                        Component parent = source.getParent();
                        RightPane.this.removeTabAt(RightPane.this.indexOfTabComponent(parent));
                    }
                }
    
                // 鼠标移上去切换关闭图标
                @Override
                public void mouseEntered(MouseEvent e) {
        
                    closeLabel.setIcon(ImageUtil.CLOSE_ENTERED_ICON);
                }
    
                // 鼠标移走，图标恢复
                @Override
                public void mouseExited(MouseEvent e) {
        
                    closeLabel.setIcon(ImageUtil.CLOSE_ICON);
                }
            });
    
            this.setSelectedIndex(count); // 切换到数据显示页
        } else {
        
            System.out.println("表单为空！");
        }
    }

效果演示  
![c9356d7895254b7c0a8be9967ce1b8a0.gif][]

### 2.8 选项卡的右键功能 ###

主要代码

// 关闭 操作
    private void closeTabAction() {
        
        rightPane.remove(selectIndex);
    }
    
    // 关闭其它 操作
    private void closeOtherTabAction() {
        
        if (selectIndex == 0) {
        
            for (int i = 1; i < tabCount; i++) {
        
                rightPane.removeTabAt(1);
            }
        } else if (selectIndex > 0) {
        
            for (int i = 1; i < selectIndex; i++) {
        
                rightPane.removeTabAt(1);
            }
            for (int i = selectIndex + 1; i < tabCount; i++) {
        
                rightPane.removeTabAt(2);
            }
        }
    }
    
    // 全部关闭 操作
    private void closeAllTabAction() {
        
        for (int i = 1; i < tabCount; i++) {
        
            rightPane.removeTabAt(1);
        }
    }
    
    // 关闭右侧选项卡 操作
    private void closeRightTabAction() {
        
        int index = selectIndex + 1;
        for (int i = index; i < tabCount; i++) {
        
            rightPane.removeTabAt(index);
        }
    }

效果演示  
![d18973ac6868c92a0ae3352d6bbc1780.gif][]

### 2.9 查询功能实现 ###

这里的查询功能实现不仅是查询功能，只要是正确的 SQL，增删改查都可执行，由于时间问题，只演示了查询功能  
主要代码

runBtn.addActionListener(e -> {
        
            this.infoArea.setText(""); // 清空信息面板
            removeResultPaneTab(); // 清空选项卡
            String text = queryArea.getText();
            if (text != null && !"".equalsIgnoreCase(text)) {
        
                String[] sqlArray = text.split(";");
                int index = 1;
                for (String sql : sqlArray) {
        
                    String lowerSql = sql.toLowerCase();
                    if (lowerSql.startsWith("insert") || lowerSql.startsWith("delete") || lowerSql.startsWith("update")) {
        
                        QueryData queryData = new QueryData(db, sql); // 直接执行 sql 语句就行
                        try {
        
                            long startTime = System.currentTimeMillis();
                            queryData.execute();
                            long endTime = System.currentTimeMillis();
                            long time = endTime - startTime;
                            appendInfo(sql, "OK", time);
                        } catch (QueryException qe) {
        
                            // 出现异常
                            appendInfo(sql, qe.getMessage(), 0);
                            resultPane.setSelectedIndex(0);
                            return;
                        }
                    } else if (lowerSql.startsWith("select")) {
        
                        try {
        
                            long startTime = System.currentTimeMillis();
                            DataTable dataTable = new DataTable(db, sql);
                            long endTime = System.currentTimeMillis();
                            long time = endTime - startTime;
                            appendInfo(sql, "OK", time);
                            resultPane.addTab("结果" + index, dataTable);
                            resultPane.setSelectedComponent(dataTable);
                            dataTable.setBorder(null);
                            index++;
                        } catch (QueryException qe) {
        
                            appendInfo(sql, qe.getMessage(), 0);
                            resultPane.setSelectedIndex(0);
                            return;
                        }
                    } else {
        
                        appendInfo(sql, "请确认 SQL 语句是否正确", 0);
                    }
                }
            }
    });

效果演示  
![5ef747d299dc17f18574abecb354e916.gif][]

## 3.源码地址 ##

Gitee：[**https://gitee.com/lijinjiang01/DBClient**][https_gitee.com_lijinjiang01_DBClient]

[849bed349c429b89fb1b153e0c450171.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/2a7dcbd709594552bd2477f69dbd6349.png
[74670b07e99ca3cd6fb5236d7deca6c9.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/d0d35a2511f14c26a19bb9842d741935.gif
[8224c053be0f41bcc6079418c42528ed.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/4178bf8116e74553baaf14ea3155d4db.gif
[d2da6c14bac01ae6061935ee33af3921.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/4a8a495b8fbd438dab9d53da8819e34f.gif
[e81cb624a4ca8265ca1597f64182eaaf.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/6c1df7f699dd48cfa4ac3840c817039a.gif
[e90e677794da24f431ba00c1ca752780.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/399fdeba7eb24387bb4df38879cd6096.gif
[c9356d7895254b7c0a8be9967ce1b8a0.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/fe086e9fe4284c5fa4a1261988dae0cb.gif
[d18973ac6868c92a0ae3352d6bbc1780.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/f8fd3b9753664683893c29f46ea93b8c.gif
[5ef747d299dc17f18574abecb354e916.gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/07/f165d185be5a4481897c1e42db05b9a9.gif
[https_gitee.com_lijinjiang01_DBClient]: https://gitee.com/lijinjiang01/DBClient