package com.zht;
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;
public class JDBC_IMP {
private String dbUrl = "jdbc:oracle:thin:@127.0.0.1:1521:orcl"; private String theUser = "test"; private String thePw = "sa"; private Connection c = null; private Statement conn; private ResultSet rs = null;
public void conJDBC() { try { System.out.println("开始连接"); Class.forName("oracle.jdbc.driver.OracleDriver").newInstance(); c = DriverManager.getConnection(dbUrl, theUser, thePw); conn = c.createStatement(); System.out.println("连接正常----------"); } catch (Exception e) { System.out.println("连接异常"); } }
public boolean executeUpdate(String sql) { try { conn.executeUpdate(sql); return true; } catch (SQLException e) { e.printStackTrace(); return false; } }
public ResultSet executeQuery(String sql) { rs = null; try { rs = conn.executeQuery(sql); } catch (SQLException e) { e.printStackTrace(); } return rs; }
public void close() { try { conn.close(); c.close(); } catch (Exception e) { e.printStackTrace(); } }
public void imp(String fileName) { try { System.out.println("导入开始-----"); // 登网站 Process process = Runtime .getRuntime() .exec( "sqlplus test/sa@orcl @g:/ccc.sql commit on"); System.out.println("导入结束-----"); } catch (Exception e) { System.out.println("导入异常-----"); } }
public static void main(String[] args) { ResultSet rs; JDBC_IMP conn = new JDBC_IMP(); conn.conJDBC(); rs = conn.executeQuery("select * from aaa"); try { while (rs.next()) { System.out.println(rs.getInt(1) + "=====" + rs.getInt(2)); } // 查询到的信息写入到本地sql文件 // 开始进行数据库导入操作 conn.imp(""); } catch (Exception e) { e.printStackTrace(); } finally { conn.close(); System.out.println("连接关闭"); }
}
}
|