package com.ruoyi;
|
|
import java.sql.*;
|
|
public class DbController {
|
|
public static void main(String[] args){
|
//test();
|
executeQuery("select * from events");
|
}
|
|
public static String executeQuery(String sql) {
|
String jsonArray = "{";
|
StringBuilder jsonObject = new StringBuilder();
|
Connection con = null;
|
Statement stmt = null;
|
ResultSet rst = null;
|
try {
|
//注册数据提供程序
|
Class.forName("org.objectweb.rmijdbc.Driver").newInstance();
|
//accessDatabase为远程服务器数据源名称
|
// String url = "jdbc:rmi://10.23.16.83/jdbc:odbc:accessDatabase";
|
//生产地址
|
String url = "jdbc:rmi://192.168.141.104:9000/jdbc:odbc:EventData";
|
// String url = "jdbc:rmi://10.23.71.211/jdbc:odbc:demo";
|
//建立连接
|
con = DriverManager.getConnection(url, "", "");
|
stmt = con.createStatement();
|
rst = stmt.executeQuery(sql);
|
if (rst != null) {
|
while (rst.next()) {
|
String id = rst.getInt("id") + "";
|
String name = new String(rst.getBytes("title"), "gbk");
|
String time = rst.getDate("adate").toString();
|
String filePath = rst.getString("url");
|
jsonObject.append("{\"ID\":\"" + id + "\", \"NAME\":\"" + name + "\", \"FILE_PATH\":\"" + filePath + "\", \"TIME\":\"" + time + "\"}, ");
|
}
|
String temp = jsonObject.toString();
|
temp = temp.substring(0, temp.length() - 2);
|
jsonArray += "\"IS_EMPTY\":\"N\",LIST:[" + temp + "]}";
|
} else {
|
jsonArray += "\"IS_EMPTY\":\"Y\"}";
|
}
|
} catch (Exception e) {
|
System.out.println("===========executeQuery start=============" + e.getMessage());
|
} finally {
|
try {
|
con.close();
|
stmt.close();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
}
|
return jsonArray;
|
}
|
|
public static void test() {
|
try {
|
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
|
String url = "jdbc:odbc:EventData";//databaseName就是刚刚添加的数据源名称
|
Connection con = DriverManager.getConnection(url, "", "");//没有用户名和密码的时候直接为空
|
Statement sta = con.createStatement();
|
ResultSet rst = sta.executeQuery("select * from events");//demoTable为access数据库中的一个表名
|
if(rst.next()){
|
System.out.println(rst.getString("name"));
|
//解决乱码问题
|
// System.out.println(new String(rst.getBytes("name"), "gbk"));
|
}
|
} catch (ClassNotFoundException e) {
|
e.printStackTrace();
|
} catch (SQLException e) {
|
e.printStackTrace();
|
} /*catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}*/
|
|
}
|
|
}
|
