|
iverManager;
import java.sql.PreparedStatement;
import java.sql.Statement;
import oracle.jdbc.driver.OracleDriver;
public class JDBC_06 {
public static void main(String[] args) throws Exception{
//加载驱动
new OracleDriver();
//连接数据库
Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:orcl", "c##scott", "root");
//创建语句
Statement stmt = conn.createStatement();
stmt.addBatch("insert into a_tab values(10001,'hello0','addbatch')");
stmt.addBatch("insert into a_tab values(10001,'hello0','addbatch')");
stmt.addBatch("insert into a_tab values(10001,'hello0','addbatch')");
/*PreparedStatement st = conn.prepareStatement("insert into a_tab values(?,?,?)") ;
st.setInt(1, 123);
st.setString(2, "xiaoxiao");
st.setString(3, "beijing");
st.addBatch();
st.setInt(1, 120);
st.setString(2, "xiaoxiao");
st.setString(3, "beijing");
st.addBatch();
st.executeBatch();
*/
stmt.executeBatch();
//关闭
stmt.close();
conn.close();
}
}
?
?
使用事务：
?
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import oracle.jdbc.OracleDriver;
public class JDBC_08 {
public static void main(String[] args) throws Exception{
//加载驱动
new OracleDriver();
//链接对象
Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:orcl","c##scott","root");
//传输对象
Statement st = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);//并发只读模式
//如果没有第一个参数 只能用resultset里面的next();
//有了这个参数 就能用所有方法
ResultSet rs = st.executeQuery("select * from a_tab");
rs.next();//从头顶进入第一行
System.out.println(rs.getInt(1));//第一行第一列
System.out.println(rs.getString(2));
System.out.println(rs.getString(3));
System.out.println(rs.getString(1));
System.out.println("----------------");
rs.last();
System.out.println(rs.getInt("id"));
System.out.println(rs.isLast() + "-----");
rs.absolute(2);
System.out.println(rs.getInt(1) + "absolute 2");
rs.previous();
System.out.println(rs.getInt(1) + "previous");
}
}
?
?
最后来个集合，对数据的基本操作：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import oracle.jdbc.driver.OracleDriver;
import oracle.net.aso.s;
public class JDBC_09 {
public static void main(String[] args) throws Exception{
//加载驱动
new OracleDriver();
//链接对象
Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:orcl","c##scott","root");
//传输对象
Statement sts = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);//并发可更新
//结果集对象
ResultSet rs = sts.executeQuery("select ID,NAME,AD from a_tab");
//结果处理
rs.next();
//增
rs.updateInt(1, 9900);//第一个字段，9999
rs.updateString("NAME", "aobama");
rs.updateString("AD", "baigong");
//rs.insertRow();//把这行插入结果集和数据库
rs.moveToCurrentRow();//把光标移动到新建的行
//删
rs.absolute(2);//移动到指定行
rs.deleteRow();//删除改行
//改
rs.updateString("NAME", "newyue");//更改内存中的数据集中的数据
rs.updateRow();//把更改的数据更新到数据库中
//关闭
rs.close();
sts.close();
conn.clo |