欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2022-03-17 15:31:51
1、先写个 mysql 的链接设置页面package com.wretchant.fredis.menu.mysql;import com.intellij.notification.notifica...

 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);
        }
    }

}

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

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、写个测试连接的类&#xff0c;测试一下 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数据库并执行查询操作的完整代码的详细内容,更多关于idea 链接mysql执行查询操作 的资料请关注其它相关文章!

相关标签: IDEA Mysql 查询