IDEA 链接Mysql数据库并执行查询操作的完整代码

 1、先写个 mysql 的链接设置页面

package com.wretchant.fredis.menu.mysql;

import com.intellij.notification.notificationtype;
import com.intellij.openapi.actionsystem.anaction;
import com.intellij.openapi.actionsystem.anactionevent;
import com.wretchant.fredis.gui.dialog.tabledialog;
import com.wretchant.fredis.util.notifyutils;
import com.wretchant.fredis.util.propertiesutils;
import org.jetbrains.annotations.notnull;

import javax.swing.*;
import java.util.map;
import java.util.properties;

/**
 * @author created by 谭健 on 2020/8/26. 星期三. 15:24.
 * © all rights reserved.
 */
public class mysqlconfig extends anaction {

    @override
    public void actionperformed(@notnull anactionevent event) {

        properties properties = propertiesutils.readfromsystem();
        if (properties != null) {
            tabledialog.tablefield build = tabledialog.tablefield.build(properties.stringpropertynames());
            tabledialog dialog = new tabledialog("mysql 连接配置", build);
            for (int i = 0; i < dialog.getlabels().size(); i++) {
                jlabel label = dialog.getlabels().get(i);
                jtextfield textfield = dialog.getinputs().get(i);
                string property = properties.getproperty(label.gettext());
                textfield.settext(property);
            }
            dialog.show();
            if (dialog.isok()) {
                map<string, string> valuemap = dialog.getvaluemap();
                valuemap.foreach(properties::setproperty);
                propertiesutils.write2system(properties);
            }
        } else {
            notifyutils.notifyuser(event.getproject(), "读取配置文件失败，配置文件不存在", notificationtype.error);
        }
    }

}

2、然后简单的写个 jdbc 操作数据库的支持类

package com.wretchant.fredis.support;

import cn.hutool.core.util.strutil;
import com.intellij.notification.notificationtype;
import com.intellij.openapi.actionsystem.anactionevent;
import com.intellij.openapi.actionsystem.platformdatakeys;
import com.intellij.openapi.editor.selectionmodel;
import com.wretchant.fredis.util.clipboardutils;
import com.wretchant.fredis.util.notifyutils;
import com.wretchant.fredis.util.propertiesutils;
import com.wretchant.fredis.value.stringvalue;
import org.apache.commons.lang.stringutils;
import org.jetbrains.annotations.notnull;

import java.sql.*;
import java.util.*;

/**
 * @author created by 谭健 on 2020/8/12. 星期三. 17:42.
 * © all rights reserved.
 */
public class mysql {


    /**
     * 执行查询语句的返回结果
     */
    public static class rs {

        public rs(list<map<string, object>> r) {
            this.r = r;
            this.count = r.size();
        }

        private list<map<string, object>> r = new arraylist<>();

        private int count;

        public list<map<string, object>> getr() {
            return r;
        }

        public void setr(list<map<string, object>> r) {
            this.r = r;
        }

        public int getcount() {
            return count;
        }

        public void setcount(int count) {
            this.count = count;
        }

        public map<string, object> one() {
            if (objects.isnull(r) || r.isempty()) {
                return null;
            }
            return r.get(0);
        }


        public object oneget(string key) {
            return one().get(key);
        }
    }


    // 参考： https://www.cnblogs.com/jyroy/p/9637149.html

    public static class jdbcutil {


        /**
         * 执行sql 并返回 map 数据
         *
         * @param sql
         * @return
         */
        public static rs rs(string sql) {
            connection connection = null;
            statement statement = null;
            resultset resultset = null;
            list<map<string, object>> r = new arraylist<>();
            try {
                connection = mysql.databaseutils.getconnection();
                statement = connection.createstatement();
                resultset = statement.executequery(sql);

                // 基础信息
                resultsetmetadata metadata = resultset.getmetadata();
                // 返回了多少个字段
                int columncount = metadata.getcolumncount();


                while (resultset.next()) {
                    map<string, object> valuemap = new linkedhashmap<>();
                    for (int i = 0; i < columncount; i++) {
                        // 这个字段是什么数据类型
                        string columnclassname = metadata.getcolumnclassname(i);
                        // 字段名称
                        string columnname = metadata.getcolumnname(i);
                        object value = resultset.getobject(columnname);
                        valuemap.put(columnname, value);
                    }
                    r.add(valuemap);
                }
            } catch (exception e1) {
                notifyutils.notifyuser(null, "error", notificationtype.error);
                e1.printstacktrace();
            } finally {
                release(connection, statement, resultset);
            }
            return new rs(r);
        }

        public static resultset es(string sql) {
            connection connection;
            statement statement;
            resultset resultset = null;
            try {
                connection = mysql.databaseutils.getconnection();
                statement = connection.createstatement();
                resultset = statement.executequery(sql);
            } catch (exception e1) {
                notifyutils.notifyuser(null, "error", notificationtype.error);
                e1.printstacktrace();
            }
            return resultset;
        }


        public static void release(connection connection, statement st, resultset rs) {
            closeconn(connection);
            closers(rs);
            closest(st);
        }

        public static void closers(resultset rs) {
            try {
                if (rs != null) {
                    rs.close();
                }
            } catch (sqlexception e) {
                e.printstacktrace();
            } finally {
                rs = null;
            }
        }

        private static void closest(statement st) {
            try {
                if (st != null) {
                    st.close();
                }
            } catch (sqlexception e) {
                e.printstacktrace();
            } finally {
                st = null;
            }
        }

        private static void closeconn(connection connection) {
            try {
                if (connection != null) {
                    connection.close();
                }
            } catch (sqlexception e) {
                e.printstacktrace();
            } finally {
                connection = null;
            }
        }

    }

    public static class databaseutils {
        private static connection connection = null;

        static {
            properties properties = propertiesutils.readfromsystem();
            try {
                if (properties != null) {
                    class.forname("com.mysql.cj.jdbc.driver");
                    connection = drivermanager.getconnection(
                            properties.getproperty("mysql.url"),
                            properties.getproperty("mysql.username"),
                            properties.getproperty("mysql.password")
                    );
                    notifyutils.notifyuser(null, "数据库连接成功", notificationtype.information);
                }
            } catch (exception e) {
                notifyutils.notifyuser(null, "数据库连接失败", notificationtype.error);
                e.printstacktrace();
            }
        }

        public static connection getconnection() {
            return connection;
        }
    }


    public static void exec(@notnull anactionevent event, template template) {
        stringvalue stringvalue = new stringvalue(template.getdefaultvalue());
        optional.ofnullable(event.getdata(platformdatakeys.editor)).
                ifpresent(editor -> {
                    selectionmodel selectionmodel = editor.getselectionmodel();
                    string selectedtext = selectionmodel.getselectedtext();
                    if (stringutils.isnotblank(selectedtext)) {
                        stringvalue.setvalue(strutil.format(template.getdynamicvalue(), selectedtext));
                    }
                });
        clipboardutils.clipboard(stringvalue.getvalue());
        notifyutils.notifyuser(event.getproject(), stringvalue.getvalue(), notificationtype.information);
    }

    /**
     * sql 语句模版
     */
    public enum template {

        select("select * from x where 1 = 1 and ", "select * from {} where 1 = 1 and ", "查询语句"),
        update("update x set x = x where 1 = 1 and ", "update {} set x = x where 1 = 1 and ", "更新语句"),
        delete("delete from x where 1 = 1 ", "delete from {} where 1 = 1 ", "删除语句"),
        insert("insert into * (x) values (x) ", "insert into {} (x) values (x) ", "新增语句"),
        ;

        template(string defaultvalue, string dynamicvalue, string describe) {
            this.defaultvalue = defaultvalue;
            this.dynamicvalue = dynamicvalue;
            this.describe = describe;
        }

        public string getdynamicvalue() {
            return dynamicvalue;
        }

        public string getdefaultvalue() {
            return defaultvalue;
        }

        public string getdescribe() {
            return describe;
        }

        /**
         * 模版内容:默认值
         */
        private final string defaultvalue;
        /**
         * 动态内容
         */
        private final string dynamicvalue;
        /**
         * 内容描述
         */
        private final string describe;


    }

}

3、写个测试连接的类，测试一下 mysql 是否可以正常链接

package com.wretchant.fredis.menu.mysql;

import com.intellij.notification.notificationtype;
import com.intellij.openapi.actionsystem.anaction;
import com.intellij.openapi.actionsystem.anactionevent;
import com.wretchant.fredis.support.mysql;
import com.wretchant.fredis.util.notifyutils;
import org.jetbrains.annotations.notnull;

import java.sql.resultset;

/**
 * @author created by 谭健 on 2020/9/15. 星期二. 10:17.
 * © all rights reserved.
 */
public class mysqlconn extends anaction {


    @override
    public void actionperformed(@notnull anactionevent event) {
        try {
            resultset es = mysql.jdbcutil.es("select 1 as ct");
            es.next();
            int ct = es.getint("ct");
            if (ct == 1) {
                notifyutils.notifyuser(null, "连接是正常的", notificationtype.information);
            } else {
                notifyutils.notifyuser(null, "连接不正常", notificationtype.error);
            }
            mysql.jdbcutil.closers(es);
        } catch (exception e1) {
            e1.printstacktrace();
            notifyutils.notifyuser(null, "连接不正常", notificationtype.error);
        }
    }
}

以上就是idea 链接mysql数据库并执行查询操作的完整代码的详细内容，更多关于idea 链接mysql执行查询操作 的资料请关注其它相关文章！