数据库连接（Oracle/sqlServer增删改查）

Posted 2020-10-14 _Jane

一、把ojdbc6.jar包导入项目中，并且Build path

二、

1.普通连接：　

　　String className="oracle.jdbc.driver.OracleDriver";//oracle的className（ojdbc6.jar）

　　String url="jdbc:oracle:thin:@127.0.0.1:1521:orcl";//oracle的url（ojdbc6.jar）

　　//String className="com.microsoft.sqlserver.jdbc.SQLServerDriver";//sqlServer的className（sqljdbc.jar）

　　//String url="jdbc:sqlserver://localhost:1433;databasename=数据库名";//sqlServer的url（sqljdbc.jar）

　　Class.forName(className);//导入驱动类

　　Connection conn=DriverManager.getConnection(url,"sa","123");//创建数据库连接对象，三个参数分别为:url,user,password
　　Statement st=conn.createStatement();
　　//新增========================begin
　　int addCount=st.executeUpdate("insert into AAA values(‘新增4‘,‘新增4‘,‘新增4‘)");
　　if(addCount>0)
　　　　System.out.println("新增成功");
　　else
　　　　System.out.println("新增失败");
　　//新增========================end

　　

　　//删除========================begin
　　int deleteCount = st.executeUpdate("delete AAA where \"id\"=‘新增4‘");
　　if(deleteCount>0)
　　System.out.println("删除成功");
　　else
　　System.out.println("删除失败");
　　//删除========================end

　　//修改========================begin
　　int updateCount=st.executeUpdate("update AAA set num =‘修改1‘, tag =‘修改1‘ where id =‘3‘");
　　if(updateCount>0)
　　　　System.out.println("修改成功");
　　else
　　　　System.out.println("修改失败");
　　//修改========================end
　　//查询========================begin
　　ResultSet rs = st.executeQuery("select * from AAA");
　　System.out.println("id \t num \t tag");
　　while(rs.next()){
　　　　String a=rs.getString(1);//根据下标取字段值，下标从1开始
　　　　String b=rs.getString("num");//根据字段名取值,get后面跟的数据类型也是和数据库来定的，可以是int/double等
　　　　String c=rs.getString(3);
　　　　System.out.println(a+"\t"+b+"\t"+c);
　　}
　　//查询========================end

　　rs.close();
　　st.close();
　　conn.close();

2.预编译连接：

　　String className="oracle.jdbc.driver.OracleDriver";//oracle的className（ojdbc6.jar）

　　String url="jdbc:oracle:thin:@127.0.0.1:1521:Magma";//oracle的url（ojdbc6.jar）

　　//String className="com.microsoft.sqlserver.jdbc.SQLServerDriver";//sqlServer的className（sqljdbc.jar）
　　//String url="jdbc:sqlserver://localhost:1433;databasename=数据库名";//sqlServer的url（sqljdbc.jar）

　　Class.forName(className);//导入驱动类
　　Connection conn=DriverManager.getConnection(url,"jczb","hxzyjczb");//创建数据库连接对象，三个参数分别为:url,user,password
　　//新增=============================begin
　　String sql="insert into AAA values(?,?,?)";
　　PreparedStatement ps = conn.prepareStatement(sql);
　　ps.setString(1, "id5");//给预编译sql传值,String类型,其它类型可以自选比如：ps.setInt(1, 199);不论字段是什么类型，只要数据可以转得过来，可以是int/double等
　　ps.setInt(2, 8);
　　ps.setString(3, "tag4");
　　int executeUpdate = ps.executeUpdate();
　　if(executeUpdate>0)
　　　　System.out.println("新增成功");
　　else
　　　　System.out.println("新增失败");
　　//新增=============================end
　　//修改=============================begin
　　String sql1="update AAA set num =?";
　　PreparedStatement ps1 = conn.prepareStatement(sql1);
　　ps1.setString(1, "4");//给预编译sql传值,String类型,其它类型可以自选比如：ps.setInt(1, 199);不论字段是什么类型，只要数据可以转得过来，可以是int/double等
　　//ps1.setString(2, "id1");
　　int executeUpdate1 = ps1.executeUpdate();
　　if(executeUpdate1>0)
　　　　System.out.println("修改成功");
　　else
　　　　System.out.println("修改失败");
　　//修改=============================end
　　//查询=============================begin
　　String sql2="select * from AAA";
　　PreparedStatement ps2 = conn.prepareStatement(sql2);
　　//预编译没有参数要传，可以不传,String类型,其它类型可以自选比如：ps.setInt(1, 199);不论字段是什么类型，只要数据可以转得过来，可以是int/double等
　　ResultSet rs = ps2.executeQuery();
　　System.out.println("id \t num \t tag \t");
　　while(rs.next()){
　　　　System.out.println(rs.getString(1)+"\t"+rs.getInt("num")+"\t"+rs.getString(3));

　　　　/get后面跟的数据类型也是和数据库或自己的需求来定的，不论字段是什么类型，只要数据可以转得过来，可以是int/double等
　　}
　　//查询=============================end
　　//新增=============================begin
　　String sql3="delete AAA where id =?";
　　PreparedStatement ps3 = conn.prepareStatement(sql3);
　　ps3.setString(1, "id2");//给预编译sql传值,String类型,其它类型可以自选比如：ps.setInt(1, 199);不论字段是什么类型，只要数据可以转得过来，可以是int/double等
　　int executeUpdate3 = ps3.executeUpdate();
　　if(executeUpdate3>0)
　　　　System.out.println("删除成功");
　　else
　　　　System.out.println("删除失败");
　　//新增=============================end
　　ps3.close();
　　conn.close();