一、البيان
معلومات المنتج:
استيراد java.sql.*;
اختبار الطبقة العامة JDBC {
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", "username", "password");
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", "username", "password");
mssql_stmt = mssql_conn.createStatement();
mssql_rs = mssql_stmt.executeQuery("select * from VideoBaseInfo");
بينما (mssql_rs.next()) {
System.out.println("معرف الفيديو:" + mssql_rs.getInt("VideoId") + "معرف الفيديو...");
oracle_stmt.executeUpdate("أدخل في قيم VIDEO_BASEINFO("
+ mssql_rs.getInt("VideoId") + ",'"
+ mssql_rs.getString("VideoName") + "','"
+ mssql_rs.getString("VideoVersion") + "'،"
+ mssql_rs.getInt("VideoMp4Items") + "،"
+ mssql_rs.getInt("VideoRmvbItems") + ",'"
+ mssql_rs.getString("VideoAliasName") + "','"
+ mssql_rs.getString("VideoAge") + "'"
+ ")");
}
} التقاط (ClassNotFoundException e) {
printStackTrace();
} قبض على (SQLException ه) {
printStackTrace();
} أخيراً {
يحاول {
إذا (Oracle_rs!= فارغة) {
oracle_rs. Close();
oracle_rs = null;
}
إذا (Oracle_stmt!= فارغة) {
oracle_stmt. Close();
oracle_stmt = null;
}
إذا (Oracle_conn!= فارغة) {
oracle_conn. Close();
oracle_conn = null;
}
إذا (mssql_rs!= فارغة) {
mssql_rs. Close();
mssql_rs = null;
}
إذا (mssql_stmt != فارغة) {
mssql_stmt. Close();
mssql_stmt = null;
}
إذا (mssql_conn!= فارغة) {
mssql_conn. Close();
mssql_conn = null;
}
} قبض على (SQLException ه) {
printStackTrace();
}
}
}
}
3、البيان المعد
معلومات المنتج:
استيراد java.sql.*;
الطبقة العامة TestPreparedStatement {
public static void main(String[] args) {
الاتصال oracle_conn = null;
PreparedStatement 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", "username", "password");
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", "username", "password");
mssql_stmt = mssql_conn.createStatement();
mssql_rs = mssql_stmt.executeQuery("select * from 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 واطلب معلومات أخرى!");
} التقاط (ClassNotFoundException e) {
printStackTrace();
} قبض على (SQLException ه) {
printStackTrace();
} أخيراً {
يحاول {
إذا (Oracle_rs!= فارغة) {
oracle_rs. Close();
oracle_rs = null;
}
إذا (Oracle_stmt!= فارغة) {
oracle_stmt. Close();
oracle_stmt = null;
}
إذا (Oracle_conn!= فارغة) {
oracle_conn.Close();
oracle_conn = null;
}
إذا (mssql_rs!= فارغة) {
mssql_rs. Close();
mssql_rs = null;
}
إذا (mssql_stmt != فارغة) {
mssql_stmt. Close();
mssql_stmt = null;
}
إذا (mssql_conn!= فارغة) {
mssql_conn. Close();
mssql_conn = null;
}
} قبض على (SQLException ه) {
printStackTrace();
}
}
}
}
3、CallableStatement
معلومات المنتج:
استيراد java.sql.*;
الطبقة العامة TestProc {
/**
* @param args
*/
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. Close();
conn.Close();
}
}
四، الدفعة
معلومات المنتج:
استيراد 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("أدخل في قيم القسم 2 (51، '500'، 'haha')");
stmt.addBatch("أدخل في قيم القسم 2 (52، '500'، 'haha')");
stmt.addBatch("أدخل في قيم القسم 2 (53، '500'، 'haha')");
stmt.executeBatch();
stmt. Close();
*/
PreparedStatement ps = conn.prepareStatement("أدخل في قيم dept2 (?, ?, ?)");
ps.setInt(1, 61);
ps.setString(2, "هاها");
ps.setString(3, "بج");
ps.addBatch();
ps.setInt(1, 62);
ps.setString(2, "هاها");
ps.setString(3, "bj");
ps.addBatch();
ps.setInt(1, 63);
ps.setString(2, "هاها");
ps.setString(3, "bj");
ps.addBatch();
ps.executeBatch();
ملاحظة: إغلاق ()؛
conn.Close();
}
}
3-المعاملة
معلومات المنتج:
استيراد 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"، "scott"، "tiger");
conn.setAutoCommit(false);
stmt = conn.createStatement();
stmt.addBatch("أدخل في قيم القسم 2 (51، '500'، 'haha')");
stmt.addBatch("أدخل في قيم القسم 2 (52، '500'، 'haha')");
stmt.addBatch("أدخل في قيم القسم 2 (53، '500'، 'haha')");
stmt.executeBatch();
conn.commit();
conn.setAutoCommit(true);
} التقاط (ClassNotFoundException e) {
printStackTrace();
} قبض على (SQLException ه) {
printStackTrace();
يحاول {
إذا (كون != فارغة)
{
conn.rollback();
conn.setAutoCommit(true);
}
} قبض على (SQLException e1) {
e1.printStackTrace();
}
}أخيراً {
يحاول {
إذا (stmt!= فارغة)
stmt. Close();
إذا (كون != فارغة)
conn.Close();
} قبض على (SQLException ه) {
printStackTrace();
}
}
}
}
、ScrollResultSet
معلومات المنتج:
استيراد java.sql.*;
الطبقة العامة TestScroll {
public static void main(String args[]) {
يحاول {
new oracle.jdbc.driver.OracleDriver();
String 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_READ_ONLY);
ResultSet rs = stmt
.executeQuery("اختر * من أمر emp بواسطة sal");
rs.next();
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.previous();
System.out.println(rs.getString(1));
rs.absolute(6);
System.out.println(rs.getString(1));
rs. Close();
stmt. Close();
conn.Close();
} قبض على (SQLException ه) {
printStackTrace();
}
}
}
七、UpdateResultSet
معلومات المنتج:
استيراد java.sql.*;
الطبقة العامة TestUpdataRs {
الفراغ الثابت العام الرئيسي(String args[]){
يحاول{
new oracle.jdbc.driver.OracleDriver();
String url="jdbc:Oracle:thin:@192.168.0.1:1521:SXT";
Connection conn=DriverManager.getConnection(url,"scott",tiger");
البيان stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet rs=stmt.executeQuery("select * from emp2");
rs.next();
// 更新一行数据
rs.updateString("ename"،"AAAA")؛
rs.updateRow();
//المصدر: 新行
rs.moveToInsertRow();
rs.updateInt(1, 9999);
rs.updateString("ename"،"AAAA")؛
rs.updateInt("mgr", 7839);
rs.updateDouble("sal", 99.99);
rs.insertRow();
//الحصول على أفضل النتائج
rs.moveToCurrentRow();
//المصدر
rs.absolute(5);
rs.deleteRow();
//取消更新
//rs.cancelRowUpdates();
}قبض على(SQLException ه){
printStackTrace();
}
}
}