import java.io.FileWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import java.io.FileInputStream;
public class JdbcUtil {
private static Properties ps = new Properties();// Properties类表示了一个持久的属性集
static {
try {
ps.load(new FileInputStream("conf/bi.properties"));// 从输入流中读取属性列表（键和元素对）。
} catch (Exception e) {
e.printStackTrace();
}
}
// Connection与TD数据库的连接（会话）。
public static Connection getTDConnection() {
try {
return DriverManager.getConnection(ps.getProperty("jdbc_td_url"),
ps.getProperty("jdbc_td_user"), ps.getProperty("jdbc_td_password"));
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
// Connection与MySQL数据库的连接（会话）。
public static Connection getMysqlConnection() {
try {
return DriverManager.getConnection(ps.getProperty("jdbc_mysql_url"),
ps.getProperty("jdbc_mysql_user"), ps.getProperty("jdbc_mysql_password"));
} catch (SQLException e) {
e.printStackTrace();
}
return null;
}
//关闭连接
public static void close(ResultSet rs, Statement st, Connection conn) {
try {
if (rs != null) {
rs.close();
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
try {
if (st != null) {
st.close();
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
}
public static void main(String[] args){
// System.out.println(ps.getProperty("jdbc_td_url")+" "+ps.getProperty("jdbc_td_user")+" "+ps.getProperty("jdbc_td_password"));
Connection conn =null;
PreparedStatement stmt = null;
ResultSet rs = null;
FileWriter fos = null;
try{
Class.forName(ps.getProperty("jdbc_td_driver"));// getResourceAsStream查找具有给定名称的资源。
fos = new FileWriter("e:\\out.txt");
conn = JdbcUtil.getTDConnection();
System.out.println(conn);
String sql = "select * from EDATA.TEST"; //SQL查询语句
stmt = conn.prepareStatement(sql);
rs = stmt.executeQuery();
while (rs.next()){
String a1=rs.getString("ID");
String a2=rs.getString("DES");
String a3=rs.getString("REQ");
fos.write(a1+"\t");
fos.write(a2+"\t");
fos.write(a3);
fos.write("\r\n"); //从TD数据库中取这3列的内容存入e:\\out.txt中
}
close(rs,stmt,conn);
}catch(Exception e){
e.printStackTrace();
}finally{
try{
fos.close();
}catch(Exception e){}
}
try{
Class.forName(ps.getProperty("jdbc_mysql_driver"));// getResourceAsStream查找具有给定名称的资源。
conn = JdbcUtil.getMysqlConnection();
System.out.println(conn);
//String sql1 = "SET NAMES UTF8;";
String sql2 = "LOAD DATA LOCAL INFILE 'E:/out.txt' INTO TABLE a1;";
//stmt = conn.prepareStatement(sql1);
//stmt.execute();
stmt = conn.prepareStatement(sql2);
stmt.executeQuery(); //从e:\\out.txt文件中取出data存入MySQL数据库的表a1中
close(rs,stmt,conn);
}catch(Exception e){
e.printStackTrace();
}
}
}
评论0