ประการหนึ่ง, คำชี้แจง
复制代码代码如下:
นำเข้า java.sql.*;
TestJDBC คลาสสาธารณะ {
โมฆะคงที่สาธารณะ main (String [] args) {
การเชื่อมต่อ oracle_conn = null;
คำสั่ง oracle_stmt = null;
ResultSet oracle_rs = null;
การเชื่อมต่อ mssql_conn = null;
คำสั่ง mssql_stmt = null;
ชุดผลลัพธ์ 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("วิดีโอ Id：" + mssql_rs.getInt("VideoId") + "วิดีโอของฉัน...");
oracle_stmt.executeUpdate("ใส่เข้าไปในค่า VIDEO_BASEINFO("
+ mssql_rs.getInt("รหัสวิดีโอ") + ">,'"
+ mssql_rs.getString("ชื่อวิดีโอ") + "','"
+ mssql_rs.getString("เวอร์ชันวิดีโอ") + "',"
+ mssql_rs.getInt("VideoMp4Items") + ","
+ mssql_rs.getInt("VideoRmvbItems") + ">,'"
+ mssql_rs.getString("VideoAliasName") + "','"
+ mssql_rs.getString("VideoAge") + "'"
-
-
} จับ (ClassNotFoundException จ) {
e.printStackTrace();
} จับ (SQLException e) {
e.printStackTrace();
} ในที่สุด {
พยายาม {
ถ้า (oracle_rs != null) {
oracle_rs.ปิด();
oracle_rs = โมฆะ;
-
ถ้า (oracle_stmt != null) {
oracle_stmt.close();
oracle_stmt = โมฆะ;
-
ถ้า (oracle_conn != null) {
oracle_conn.ปิด();
oracle_conn = โมฆะ;
-
ถ้า (mssql_rs != null) {
mssql_rs.ปิด();
mssql_rs = โมฆะ;
-
ถ้า(mssql_stmt != null) {
mssql_stmt.ปิด();
mssql_stmt = โมฆะ;
-
ถ้า (mssql_conn != null) {
mssql_conn.ปิด();
mssql_conn = โมฆะ;
-
} จับ (SQLException e) {
e.printStackTrace();
-
-
-
-
二、คำแถลงที่เตรียมไว้
复制代码代码如下:
นำเข้า java.sql.*;
TestPreparedStatement ระดับสาธารณะ {
โมฆะคงที่สาธารณะ main (String [] args) {
การเชื่อมต่อ oracle_conn = null;
คำสั่งที่เตรียมไว้ oracle_stmt = null;
ResultSet oracle_rs = null;
การเชื่อมต่อ mssql_conn = null;
คำสั่ง mssql_stmt = null;
ชุดผลลัพธ์ 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("รายการสินค้าIndex：" + mssql_rs.getInt("ItemIndex") + "รายการสินค้า...");
oracle_stmt.setInt(1, mssql_rs.getInt("ItemIndex"));
oracle_stmt.setInt(2, mssql_rs.getInt("รหัสวิดีโอ"));
oracle_stmt.setString(3, mssql_rs.getString("VideoItemName"));
oracle_stmt.setString(4, mssql_rs.getString("VideoExtName"));
oracle_stmt.setDouble(5, mssql_rs.getDouble("ขนาดวิดีโอ"));
oracle_stmt.setString(6, mssql_rs.getString("VideoPath"));
oracle_stmt.setString(7, mssql_rs.getString("ประเภทวิดีโอ"));
oracle_stmt.setDate(8, mssql_rs.getDate("วันที่วิดีโอ"));
oracle_stmt.setString(9, mssql_rs.getString("ApplicationWay"));
oracle_stmt.executeUpdate();
-
System.out.println("插入数据到Video_ItemInfo表中操作已完成!");
} จับ (ClassNotFoundException จ) {
e.printStackTrace();
} จับ (SQLException e) {
e.printStackTrace();
} ในที่สุด {
พยายาม {
ถ้า (oracle_rs != null) {
oracle_rs.ปิด();
oracle_rs = โมฆะ;
-
ถ้า (oracle_stmt != null) {
oracle_stmt.close();
oracle_stmt = โมฆะ;
-
ถ้า (oracle_conn != null) {
oracle_conn.ปิด();
oracle_conn = โมฆะ;
-
ถ้า (mssql_rs != null) {
mssql_rs.ปิด();
mssql_rs = โมฆะ;
-
ถ้า(mssql_stmt != null) {
mssql_stmt.ปิด();
mssql_stmt = โมฆะ;
-
ถ้า (mssql_conn != null) {
mssql_conn.ปิด();
mssql_conn = โมฆะ;
-
} จับ (SQLException e) {
e.printStackTrace();
-
-
-
-
๓. CallableStatement
复制代码代码如下:
นำเข้า java.sql.*;
TestProc คลาสสาธารณะ {
-
* @param args
-
โมฆะคงที่สาธารณะ main (String [] args) พ่นข้อยกเว้น {
Class.forName("oracle.jdbc.driver.OracleDriver");
การเชื่อมต่อ conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.1:1521:SXT", "scott", "tiger");
CallableStatement cstmt = conn.prepareCall("{call p(?, ?, ?, ?)}");
cstmt.registerOutParameter(3, ประเภทจำนวนเต็ม);
cstmt.registerOutParameter(4, ประเภท.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.ปิด();
conn.ปิด();
-
-
四、แบทช์
复制代码代码如下:
นำเข้า java.sql.*;
TestBatch ระดับสาธารณะ {
โมฆะคงที่สาธารณะ main (String [] args) พ่นข้อยกเว้น {
Class.forName("oracle.jdbc.driver.OracleDriver");
การเชื่อมต่อ conn = DriverManager.getConnection("jdbc:oracle:thin:@192.168.0.1:1521:SXT", "scott", "tiger");
-
คำสั่ง stmt = conn.createStatement();
stmt.addBatch("ใส่ค่า dept2 (51, '500', '555')");
stmt.addBatch("ใส่ค่า dept2 (52, '500', '555')");
stmt.addBatch("ใส่ค่า dept2 (53, '500', '555')");
stmt.executeBatch();
stmt.ปิด();
-
PreparedStatement ps = conn.prepareStatement("แทรกลงในค่า dept2 (?, ?, ?)");
PS.setInt(1, 61);
ps.setString(2, "555");
ps.setString(3, "bj");
ปล.addBatch();
PS.setInt(1, 62);
ps.setString(2, "555");
ps.setString(3, "bj");
ปล.addBatch();
PS.setInt(1, 63);
ps.setString(2, "555");
ps.setString(3, "bj");
ปล.addBatch();
PS.executeBatch();
ปล.ปิด();
conn.ปิด();
-
-
五、ธุรกรรม
复制代码代码如下:
นำเข้า java.sql.*;
TestTransaction ระดับสาธารณะ {
โมฆะคงที่สาธารณะ main (String [] args) {
การเชื่อมต่อการเชื่อมต่อ = null;
คำสั่ง stmt = null;
พยายาม {
Class.forName("oracle.jdbc.driver.OracleDriver");
conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:SXT", "scott", "tiger");
conn.setAutoCommit(เท็จ);
stmt = conn.createStatement();
stmt.addBatch("ใส่ค่า dept2 (51, '500', '555')");
stmt.addBatch("ใส่ค่า dept2 (52, '500', '555')");
stmt.addBatch("ใส่ค่า dept2 (53, '500', '555')");
stmt.executeBatch();
conn.commit();
conn.setAutoCommit(จริง);
} จับ (ClassNotFoundException จ) {
e.printStackTrace();
} จับ (SQLException e) {
e.printStackTrace();
พยายาม {
ถ้า(conn != null)
-
conn.ย้อนกลับ();
conn.setAutoCommit(จริง);
-
} จับ (SQLException e1) {
e1.printStackTrace();
-
}ในที่สุด {
พยายาม {
ถ้า(stmt != null)
stmt.ปิด();
ถ้า(conn != null)
conn.ปิด();
} จับ (SQLException e) {
e.printStackTrace();
-
-
-
-
六、ScrollResultSet
复制代码代码如下:
นำเข้า java.sql.*;
TestScroll คลาสสาธารณะ {
โมฆะคงสาธารณะ main (String args []) {
พยายาม {
ใหม่ oracle.jdbc.driver.OracleDriver();
URL สตริง = "jdbc:oracle:thin:@192.168.0.1:1521:SXT";
การเชื่อมต่อการเชื่อมต่อ = DriverManager
.getConnection(url, "scott", "tiger");
คำสั่ง stmt = conn.createStatement(
ResultSet.TYPE_SCROLL_INSENSITIVE,
ResultSet.CONCUR_READ_ONLY);
ResultSet rs = stmt
.executeQuery("select * from emp order by sal");
rs.ถัดไป();
System.out.println(rs.getInt(1));
rs.สุดท้าย();
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));
อาร์เอสสัมบูรณ์(6);
System.out.println(rs.getString(1));
rs.ปิด();
stmt.ปิด();
conn.ปิด();
} จับ (SQLException e) {
e.printStackTrace();
-
-
-
3. UpdateResultSet
复制代码代码如下:
นำเข้า java.sql.*;
TestUpdataRs คลาสสาธารณะ {
โมฆะคงที่สาธารณะ main (String args []) {
พยายาม{
ใหม่ oracle.jdbc.driver.OracleDriver();
สตริง url="jdbc:oracle:thin:@192.168.0.1:1521:SXT";
การเชื่อมต่อ conn=DriverManager.getConnection(url,"scott", "tiger");
คำสั่ง stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet rs=stmt.executeQuery("select * from emp2");
rs.ถัดไป();
//更新一行数据
rs.updateString("ename,"AAAA");
rs.updateRow();
//插入新行
rs.moveToInsertRow();
rs.updateInt(1, 9999);
rs.updateString("ename,"AAAA");
rs.updateInt("mgr", 7839);
rs.updateDouble("ซัล", 99.99);
rs.insertRow();
//将光标移动到新建的行
rs.moveToCurrentRow();
//删除行
อาร์เอสสัมบูรณ์(5);
rs.deleteRow();
//取消更新
//rs.cancelRowUpdates();
} จับ (SQLException e){
e.printStackTrace();
-
-
-