一、前言

關于實現(xiàn)mysql數(shù)據(jù)簡單操作工具類MySQLUtils，用戶密碼連接數(shù)據(jù)庫執(zhí)行sql腳本ExecSQL、將查詢結果轉(zhuǎn)為com.alibaba.fastjson.JSONArray(fastjson)等常用操作。

二、代碼示例import?java.io.BufferedReader;@b@import?java.io.FileReader;@b@import?java.sql.Connection;@b@import?java.sql.DriverManager;@b@import?java.sql.ResultSet;@b@import?java.sql.ResultSetMetaData;@b@import?java.sql.Statement;@b@import?java.util.ArrayList;@b@import?java.util.List;@b@@b@import?com.alibaba.fastjson.JSONArray;@b@import?com.alibaba.fastjson.JSONObject;@b@@b@public?class?MySQLUtils?{@b@@b@public?static?class?ExecSQL?{@b@@b@public?final?String?url;@b@public?final?String?sql;@b@public?final?String?user;@b@public?final?String?passwd;@b@@b@public?ExecSQL(String?host,?String?user,?String?passwd,?String?db,?String?sql)?{@b@this.url?=?String.format("jdbc:mysql://%s/%s?characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull",?host,?db);@b@this.sql?=?sql;@b@this.user?=?user;@b@this.passwd?=?passwd;@b@}@b@@b@public?ExecSQL(String?full_host,?String?user,?String?passwd,?String?sql)?{@b@this.url?=?full_host;@b@this.sql?=?sql;@b@this.user?=?user;@b@this.passwd?=?passwd;@b@}@b@}@b@@b@public?static?boolean?exec(ExecSQL?execSQL)?{@b@Connection?conn?=?null;@b@Statement?stmt?=?null;@b@try?{@b@Class.forName("com.mysql.jdbc.Driver");@b@conn?=?DriverManager.getConnection(execSQL.url,?execSQL.user,?execSQL.passwd);@b@stmt?=?conn.createStatement();@b@return?stmt.execute(execSQL.sql);@b@}?catch?(Exception?e)?{@b@e.printStackTrace();@b@}?finally?{@b@if?(stmt?!=?null)?try?{?stmt.close();?}?catch?(Exception?e2)?{}@b@if?(conn?!=?null)?try?{?conn.close();?}?catch?(Exception?e2)?{}@b@}@b@return?false;@b@}@b@@b@public?static?JSONArray?query(ExecSQL?execSQL)?{@b@JSONArray?ret?=?null;@b@Connection?conn?=?null;@b@Statement?stmt?=?null;@b@ResultSet?rs?=?null;@b@try?{@b@Class.forName("com.mysql.jdbc.Driver");@b@conn?=?DriverManager.getConnection(execSQL.url,?execSQL.user,?execSQL.passwd);@b@stmt?=?conn.createStatement();@b@rs?=?stmt.executeQuery(execSQL.sql);@b@ret?=?convert2(rs);@b@}?catch?(Exception?e)?{@b@e.printStackTrace();@b@}?finally?{@b@if?(rs?!=?null)?try?{?rs.close();?}?catch?(Exception?e2)?{}@b@if?(stmt?!=?null)?try?{?stmt.close();?}?catch?(Exception?e2)?{}@b@if?(conn?!=?null)?try?{?conn.close();?}?catch?(Exception?e2)?{}@b@}@b@return?ret;@b@}@b@@b@public?static?JSONArray?convert2(ResultSet?rs)?throws?Exception?{@b@JSONArray?json?=?new?JSONArray();@b@ResultSetMetaData?rsmd?=?rs.getMetaData();@b@int?numColumns?=?rsmd.getColumnCount();@b@JSONArray?th?=?new?JSONArray();@b@for?(int?i=1;?i?parseFile(String?sql_file)?throws?Exception?{@b@List?ret?=?new?ArrayList();@b@String?file_dir?=?sql_file.substring(0,?sql_file.lastIndexOf('/')?+?1);@b@BufferedReader?reader?=?null;@b@try?{@b@reader?=?new?BufferedReader(new?FileReader(sql_file));@b@StringBuffer?sqlBuf?=?new?StringBuffer();@b@String?line;@b@boolean?skip?=?false;@b@while?((line?=?reader.readLine())?!=?null)?{@b@line?=?line.trim();@b@if?(line.toUpperCase().startsWith("DELIMITER"))?{@b@skip?=?!line.endsWith(";");@b@continue;@b@}?else?if?(skip?||?line.startsWith("--"))?{@b@continue;@b@}@b@@b@sqlBuf.append(line);@b@if?(line.endsWith(";"))?{@b@String?sql?=?sqlBuf.toString().trim();@b@sqlBuf?=?new?StringBuffer();@b@if?(sql.startsWith("source?"))?{@b@String?source_file?=?sql.replace("source",?"").replace(";",?"").trim();@b@ret.addAll(parseFile(file_dir?+?source_file));@b@}?else?{@b@ret.add(sql);@b@}@b@}?else?{@b@sqlBuf.append("?");@b@}@b@}@b@}?finally?{@b@if?(reader?!=?null)?try?{?reader.close();?}?catch?(Exception?e)?{?}@b@}@b@return?ret;@b@}@b@}

總結

以上是生活随笔為你收集整理的mysql util_关于mysql数据库操作工具类MySQLUtils用于连接数据提交sql脚本及结果转为JSONArray等操作...的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。