一、Заявление
复制代码代码如下:
импортировать java.sql.*;
общественный класс TestJDBC {
public static void main(String[] args) {
Соединение oracle_conn = null;
Заявление oracle_stmt = null;
ResultSet oracle_rs = null;
Соединение mssql_conn = null;
Заявление mssql_stmt = null;
ResultSet mssql_rs = null;
пытаться {
Class.forName("oracle.jdbc.driver.OracleDriver");
oracle_conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.215:1521:orcl", "имя пользователя", "пароль");
oracle_stmt = oracle_conn.createStatement();
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
mssql_conn = DriverManager.getConnection("jdbc:sqlserver://192.168.0.213:1433;DatabaseName=VIS", "имя пользователя", "пароль");
mssql_stmt = mssql_conn.createStatement();
mssql_rs = mssql_stmt.executeQuery("выберите * из VideoBaseInfo");
в то время как (mssql_rs.next()) {
System.out.println("Подробнее VideoId:" + mssql_rs.getInt("VideoId") + "的记录...");
oracle_stmt.executeUpdate("вставить в значения VIDEO_BASEINFO("
+ mssql_rs.getInt("VideoId") + ",'"
+ mssql_rs.getString("ИмяВидео") + "','"
+ mssql_rs.getString("VideoVersion") + "',"
+ mssql_rs.getInt("VideoMp4Items") + ","
+ mssql_rs.getInt("VideoRmvbItems") + ",'"
+ mssql_rs.getString("VideoAliasName") + "','"
+ mssql_rs.getString("VideoAge") + "'"
+ ")");
}
} catch (ClassNotFoundException e) {
е.printStackTrace();
} catch (SQLException e) {
е.printStackTrace();
} окончательно {
пытаться {
если (oracle_rs! = ноль) {
oracle_rs.close();
oracle_rs = ноль;
}
если (oracle_stmt! = ноль) {
oracle_stmt.close();
oracle_stmt = ноль;
}
если (oracle_conn! = ноль) {
oracle_conn.close();
oracle_conn = ноль;
}
если (mssql_rs! = ноль) {
mssql_rs.close();
mssql_rs = ноль;
}
если (mssql_stmt! = ноль) {
mssql_stmt.close();
mssql_stmt = ноль;
}
если (mssql_conn! = ноль) {
mssql_conn.close();
mssql_conn = ноль;
}
} catch (SQLException e) {
е.printStackTrace();
}
}
}
}
二、PreparedStatement
复制代码代码如下:
импортировать java.sql.*;
общественный класс TestPreparedStatement {
public static void main(String[] args) {
Соединение oracle_conn = null;
ReadedStatement oracle_stmt = null;
ResultSet oracle_rs = null;
Соединение mssql_conn = null;
Заявление mssql_stmt = null;
ResultSet mssql_rs = null;
пытаться {
Class.forName("oracle.jdbc.driver.OracleDriver");
oracle_conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.215:1521:orcl", "имя пользователя", "пароль");
oracle_stmt = oracle_conn.prepareStatement("вставить в значения Video_ItemInfo(?, ?, ?, ?, ?, ?, ?, ?, ?)");
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
mssql_conn = DriverManager.getConnection("jdbc:sqlserver://192.168.0.213:1433;DatabaseName=VIS", "имя пользователя", "пароль");
mssql_stmt = mssql_conn.createStatement();
mssql_rs = mssql_stmt.executeQuery("выберите * из VideoItemInfo");
в то время как (mssql_rs.next()) {
System.out.println("Индекс ItemIndex:" + mssql_rs.getInt("ItemIndex") + "的记录...");
oracle_stmt.setInt(1, mssql_rs.getInt("ItemIndex"));
oracle_stmt.setInt(2, mssql_rs.getInt("VideoId"));
oracle_stmt.setString(3, mssql_rs.getString("VideoItemName"));
oracle_stmt.setString(4, mssql_rs.getString("VideoExtName"));
oracle_stmt.setDouble(5, mssql_rs.getDouble("VideoSize"));
oracle_stmt.setString(6, mssql_rs.getString("VideoPath"));
oracle_stmt.setString(7, mssql_rs.getString("VideoType"));
oracle_stmt.setDate(8, mssql_rs.getDate("VideoDate"));
oracle_stmt.setString(9, mssql_rs.getString("ApplicationWay"));
oracle_stmt.executeUpdate();
}
System.out.println("插入数据到Video_ItemInfo表中操作已完成！");
} catch (ClassNotFoundException e) {
е.printStackTrace();
} catch (SQLException e) {
е.printStackTrace();
} окончательно {
пытаться {
если (oracle_rs! = ноль) {
oracle_rs.close();
oracle_rs = ноль;
}
если (oracle_stmt! = ноль) {
oracle_stmt.close();
oracle_stmt = ноль;
}
если (oracle_conn! = ноль) {
oracle_conn.close();
oracle_conn = ноль;
}
если (mssql_rs! = ноль) {
mssql_rs.close();
mssql_rs = ноль;
}
если (mssql_stmt! = ноль) {
mssql_stmt.close();
mssql_stmt = ноль;
}
если (mssql_conn! = ноль) {
mssql_conn.close();
mssql_conn = ноль;
}
} catch (SQLException e) {
е.printStackTrace();
}
}
}
}
三、CallableStatement
复制代码代码如下:
импортировать java.sql.*;
общественный класс TestProc {
/**
* @param аргументы
*/
public static void main(String[] args) выдает исключение {
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.1:1521:SXT", "scott", "tiger");
CallableStatement cstmt = conn.prepareCall("{call p(?, ?, ?, ?)}");
cstmt.registerOutParameter(3, Types.INTEGER);
cstmt.registerOutParameter(4, Types.INTEGER);
cstmt.setInt(1, 3);
cstmt.setInt(2, 4);
cstmt.setInt(4, 5);
cstmt.execute();
System.out.println(cstmt.getInt(3));
System.out.println(cstmt.getInt(4));
cstmt.закрыть();
конн.закрыть();
}
}
四、Пакет
复制代码代码如下:
импортировать java.sql.*;
общественный класс TestBatch {
public static void main(String[] args) выдает исключение {
Class.forName("oracle.jdbc.driver.OracleDriver");
Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.1:1521:SXT", "scott", "tiger");
/*
Заявление stmt = conn.createStatement();
stmt.addBatch("вставить в dept2 значения (51, '500', 'ха-ха')");
stmt.addBatch("вставить в значения dept2 (52, '500', 'ха-ха')");
stmt.addBatch("вставить в dept2 значения (53, '500', 'ха-ха')");
stmt.executeBatch();
стмт.закрыть();
*/
ReadedStatement ps = conn.prepareStatement("вставить в значения dept2 (?, ?, ?)");
ps.setInt(1, 61);
ps.setString(2, «ха-ха»);
ps.setString(3, "ЛЮ");
пс.addBatch();
ps.setInt(1, 62);
ps.setString(2, «ха-ха»);
ps.setString(3, "ЛЮ");
пс.addBatch();
ps.setInt(1, 63);
ps.setString(2, «ха-ха»);
ps.setString(3, "ЛЮ");
пс.addBatch();
ps.executeBatch();
пс.закрыть();
конн.закрыть();
}
}
五、Транзакция
复制代码代码如下:
импортировать java.sql.*;
общественный класс TestTransaction {
public static void main(String[] args) {
Соединение конн = ноль;
Заявление stmt = null;
пытаться {
Class.forName("oracle.jdbc.driver.OracleDriver");
conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:SXT", "Скотт", "тигр");
conn.setAutoCommit(ложь);
stmt = conn.createStatement();
stmt.addBatch("вставить в dept2 значения (51, '500', 'ха-ха')");
stmt.addBatch("вставить в значения dept2 (52, '500', 'ха-ха')");
stmt.addBatch("вставить в dept2 значения (53, '500', 'ха-ха')");
stmt.executeBatch();
конн.коммит();
conn.setAutoCommit(истина);
} catch (ClassNotFoundException e) {
е.printStackTrace();
} catch(SQLException e) {
е.printStackTrace();
пытаться {
если (подключение! = ноль)
{
конн.откат();
conn.setAutoCommit(истина);
}
} поймать (SQLException e1) {
e1.printStackTrace();
}
}окончательно {
пытаться {
если (stmt! = ноль)
стмт.закрыть();
если (подключение! = ноль)
конн.закрыть();
} catch (SQLException e) {
е.printStackTrace();
}
}
}
}
、ScrollResultSet.
复制代码代码如下:
импортировать java.sql.*;
общественный класс TestScroll {
public static void main(String args[]) {
пытаться {
новый oracle.jdbc.driver.OracleDriver();
Строка URL = "jdbc:oracle:thin:@192.168.0.1:1521:SXT";
Подключение подключения = DriverManager
.getConnection(url, «Скотт», «тигр»);
Заявление stmt = conn.createStatement(
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
Набор результатов rs = stmt
.executeQuery("выберите * из заказа emp по sal");
рс.следующий();
System.out.println(rs.getInt(1));
rs.last();
System.out.println(rs.getString(1));
System.out.println(rs.isLast());
System.out.println(rs.isAfterLast());
System.out.println(rs.getRow());
rs.предыдущий();
System.out.println(rs.getString(1));
rs.absolute(6);
System.out.println(rs.getString(1));
рс.закрыть();
стмт.закрыть();
конн.закрыть();
} catch (SQLException e) {
е.printStackTrace();
}
}
}
七、UpdateResultSet
复制代码代码如下:
импортировать java.sql.*;
общественный класс TestUpdataRs {
public static void main(String args[]){
пытаться{
новый oracle.jdbc.driver.OracleDriver();
String url="jdbc:oracle:thin:@192.168.0.1:1521:SXT";
Connection conn=DriverManager.getConnection(url,"Скотт","тигр");
Заявление stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet rs=stmt.executeQuery("выберите * из emp2");
рс.следующий();
//更新一行数据
rs.updateString("ename","AAAA");
rs.updateRow();
//插入新行
rs.moveToInsertRow();
rs.updateInt(1, 9999);
rs.updateString("ename","AAAA");
rs.updateInt("мгр", 7839);
rs.updateDouble("сал", 99,99);
rs.insertRow();
//将光标移动到新建的行
rs.moveToCurrentRow();
//删除行
rs.absolute(5);
rs.deleteRow();
//取消更新
//rs.cancelRowUpdates();
}catch(SQLException e){
е.printStackTrace();
}
}
}