rd);
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(strSql);
List> listMap = new ArrayList>();
while (rs.next()) {
Map map = new HashMap();
ResultSetMetaData rsmd = rs.getMetaData();
for (int i = 1; i <= rsmd.getColumnCount(); i++) {
String columnName = rsmd.getColumnName(i);
Object objValue = rs.getObject(columnName);
map.put(columnName, objValue);
}
listMap.add(map);
}
return listMap;
}
/**
* Access增删改
* @param database
* @param user_id
* @param password
* @param sql
*/
public static void createAccessSQLExecute(String database, String user_id, String password, String sql) {
Statement stmt = null;
try {
Connection con = ConnectionDbUtils.getAccessConnection(database, user_id, password);
stmt = con.createStatement();
int i = stmt.executeUpdate(sql);
System.out.println("执行sql语句：" + sql);
System.out.println("处理成功！处理条数为" + i);
}
catch (Exception e) {
e.printStackTrace();
System.out.println("执行失败，请检查远程数据库是否打开服务");
}
finally {
try {
if (null != stmt) {
stmt.close();
}
}
catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* oracle 查询数据
* @param server
* @param database
* @param user_id
* @param password
* @param strSql
* @return
* @throws Exception
*/
public static List> queryOracleData(String server, String database, String user_id,
String password, String strSql) throws Exception {
Connection con = ConnectionDbUtils.getOracleConnection(server, database, user_id, password);
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(strSql);
List> listMap = new ArrayList>();
while (rs.next()) {
Map map = new HashMap();
ResultSetMetaData rsmd = rs.getMetaData();
for (int i = 1; i <= rsmd.getColumnCount(); i++) {
String columnName = rsmd.getColumnName(i);
Object objValue = rs.getObject(columnName);
map.put(columnName, objValue);
}
listMap.add(map);
}
return listMap;
}
/**
* oracle增删改
* @param server
* @param database
* @param user_id
* @param password
* @param sql
*/
public static void createOracleSQLExecute(String server, String database, String user_id, String password,
String sql) {
Statement stmt = null;
try {
Connection con = ConnectionDbUtils.getOracleConnection(server, database, user_id, password);
stmt = con.createStatement();
System.out.println("执行sql语句：" + sql);
int i = stmt.executeUpdate(sql);
System.out.println("处理成功！处理条数为" + i);
}
catch (Exception e) {
e.printStackTrace();
System.out.println("执行失败，请检查远程数据库是否打开服务");
}
finally {
try {
if (null != stmt) {
stmt.close();
}
}
catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 查询数据(sql server)
*
* @param server 服务器
* @param database 数据库名
* @param user_id 用户名
* @param password 密码
* @param strSql sql语句
* @return List>
* @throws Exception
*/
public static List> querySqlServerData(String server, String database, String user_id,
String password, String strSql) throws Exception {
Connection con = ConnectionDbUtils.getSqlServerConnection(server, database, user_id, password);
Statement stmt = con.createStatement();
System.out.println("querySqlServerData的sql语句===========" + strSql);
ResultSet rs = stmt.executeQuery(strSql);
List> listMap = new ArrayList>();
while (rs.next()) {
Map map = new HashMap();
ResultSetMetaData rsmd = rs.getMetaData();
for (int i = 1; i <= rsmd.getColumnCount(); i++) {
String columnName = rsmd.getColumnName(i);
Object objValue = rs.getObject(columnName);
map.put(columnName, objValue);
}
listMap.add(map);
}
return listMap;
}
/**
* 执行sql的添加、修改、删除操作
*
* @param conn
* @param sql
*/
public static void createSQLExecute(String server, String database, String user_id, String password,
List sql) {
Statement stmt = null;
try {
Connection con = ConnectionDbUtils.getSqlServerConnection(server, database, user_id, password);
stmt = con.createStatement();
for (String s : sql) {
System.out.println("执行sql语句：" + sql);
int i = stmt.executeUpdate(s);
System.out.println("处理成功！处理条数为" + i);
}
}
catch (Exception e) {
e.printStackTrace();
System.out.println("执行失败，请检查远程数据库是否打开服务");
}
finally {
try {
if (null != stmt) {
stmt.close();
}
}
catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 执行sql的添加、修改、删除操作
*
* @param conn
* @param sql
*/
public static void createSQLExecute(String server, String database, String user_id, String password, String sql) {
Statement stmt = null;
try {
System.out.println("执行sql语句：" + sql);
Connection con = ConnectionDbUtils.getSqlServerConnection(server, database, user_id, password);
stmt = con.createStatement();
int i = stmt.executeUpdate(sql);
System.out.println("处理成功！处理条数为" + i);
}
catch (Exception e) {
e.printStackTrace();
System.out.println("执行失败，请检查远程数据库是否打开服务");
}
finally {
try {
if (null != stmt) {
stmt.close();
}
}
catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* MySql 查询数据
* @param server
* @param database
* @param user_id
* @param password
* @param strSql
* @return
* @throws Exception
*/
public static List> queryMySqlData(String server, String database, String user_id,
String password, String sql) throws Exception {
Connection con = ConnectionDbUtils.getMySqlConnection(server, database, user_id, password);
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(sql);
List> listMap = new ArrayList>();
while (rs.next()) {
Map map = new HashMap();
ResultSetMetaData rsmd = rs.getMetaData();
for (int i = 1; i <= rsmd.getColumnCount(); i++) {
String columnName = rsmd.getColumnName(i);
Object objValue = rs.getObject(columnName);
map.put(columnName, objValue);
}
listMap.add(map);
}
return listMap;
}
/**
* 执行MySql的增删改
* @param server
* @param database
* @param user_id
* @param password
* @param sql
*/
public static void createMySqlExecute(String server,String database,String user_id,String password,String sql){
Connection con=null;
Statement stmt = null;
try {
System.out.println("执行sql语句：" + sql);
con= ConnectionDbUtils.getMySqlConnection(server, database, user_id, password);
stmt = con.createStatement();
int successCount = stmt.executeUpdate(sql);
System.out.println("处理成功！处理条数为" + successCount);
}
catch (Exception e) {
e.printStackTrace();
System.out.println("执行失败，请检查远程数据库是否打开服务");
}
finally {
try {
if (null != stmt) {
stmt.close();
}
}
catch (SQLException e) {
e.printStackTrace();
}
}
}
}
|