package com.baoshan.connection;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.baoshan.wholeVariable.GetPath;
public class newSqlserverDBConnection {
Connection conn = null;
Statement stmt = null;
ResultSet rsrs = null;
ResultSet rsrsrs = null;
public ResultSet executeQuery(String sql) throws SQLException
{
GetPath g = new GetPath();
String sqlUrl = g.getSqlConUrl();
String sqlUser = g.getSqlConUser();
String sqlPassWord = g.getSqlConPassWord();
try
{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
conn = DriverManager.getConnection(sqlUrl,sqlUser,sqlPassWord);
Statement statement = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rsrs = statement.executeQuery(sql);
return rsrs;
}
catch (Exception e)
{
System.err.println("error: " + e.getMessage());
return rsrs;
}
}
public ResultSet executeEnvManageMentQuery(String sql) throws SQLException
{
GetPath g = new GetPath();
String sqlUrl = g.getEnvManageMentSqlConUrl();
String sqlUser = g.getEnvManageMentSqlConUser();
String sqlPassWord = g.getEnvManageMentSqlConPassWord();
try
{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
conn = DriverManager.getConnection(sqlUrl,sqlUser,sqlPassWord);
Statement statement = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rsrs = statement.executeQuery(sql);
return rsrs;
}
catch (Exception e)
{
System.err.println("error: " + e.getMessage());
return rsrs;
}
}
public ResultSet executeSDEQuery(String sql) throws SQLException
{
GetPath g = new GetPath();
String OracleUrl = g.getOracleConUrl();
String OracleUser = g.getOracleConUser();
String OraclePassWord = g.getOracleConPassWord();
try
{
//System.out.println(sql);
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
// System.out.println("----------"+OracleUrl);
// System.out.println("==========="+OracleUser);
// System.out.println("==========="+OraclePassWord);
conn = DriverManager.getConnection(OracleUrl,OracleUser,OraclePassWord);
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rsrs = stmt.executeQuery(sql);
return rsrs;
}
catch (Exception e)
{
e.printStackTrace();
System.out.println("netzero(String): " + e.getMessage());
return rsrs;
}
}
public ResultSet executeWasteWaterQuery(String sql) throws SQLException
{
GetPath g = new GetPath();
String wasteWaterUrl = g.getWasteWaterSqlConUrl();
String wasteWaterUser = g.getWasteWaterSqlConUser();
String wasteWaterPassWord = g.getWasteWaterSqlConPassWord();
try
{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
conn = DriverManager.getConnection(wasteWaterUrl,wasteWaterUser,wasteWaterPassWord);
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rsrs = stmt.executeQuery(sql);
return rsrs;
}
catch (Exception e)
{
e.printStackTrace();
System.out.println("netzero(String): " + e.getMessage());
return rsrs;
}
}
public ResultSet executeEnvQualityQuery(String sql) throws SQLException
{
GetPath g = new GetPath();
String wasteWaterUrl = g.getWasteWaterSqlConUrl();
String wasteWaterUser = g.getWasteWaterSqlConUser();
String wasteWaterPassWord = g.getWasteWaterSqlConPassWord();
try
{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
conn = DriverManager.getConnection(wasteWaterUrl,wasteWaterUser,wasteWaterPassWord);
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rsrs = stmt.executeQuery(sql);
return rsrs;
}
catch (Exception e)
{
e.printStackTrace();
System.out.println("netzero(String): " + e.getMessage());
return rsrs;
}
}
public void executeUpdate(String sql) throws SQLException
{
try
{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=lhjgis","sa","qike");
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
stmt.executeUpdate(sql);
stmt.close();
conn.close();
}
catch (Exception e)
{
System.out.println("netzero(String): " + e.getMessage());
}finally{
close();
}
}
public Connection getconn(){
try{
Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
//conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://sdeserver\\xhtest;DatabaseName=publicinfo_xh","sa","none");
conn = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=lhjgis","sa","qike");
return conn;
}catch(Exception e){
return null;
}
}
public void close() throws SQLException
{
try
{
if(stmt != null)stmt.close();
}
catch ( Exception ex )
{
System.err.println("closeConn: " + ex.getMessage());
}
try
{
if(conn != null)conn.close();
}
catch ( Exception ex )
{
System.err.println("closeConn: " + ex.getMessage());
}
try
{
if(rsrs != null)rsrs.close();
}
catch ( Exception ex )
{
System.err.println("closeConn: " + ex.getMessage());
}
//System.out.println("++++++++++++++++++++++: "+conn.isClosed());
}
//-- 判断strObj是否为空值
public String chkString(String strObj,String strReturn){
if(strObj == null) return strReturn;
else if( strObj.trim().equals("")|| strObj.trim().toLowerCase().equals("null")) return strReturn;
else return strObj;
}
}
评论0