如何使用java对oracle数据库进行增删查改？.docx

如何使用java对oracle数据库进行增删查改？ 2008-9-2 11:48 提问者：pesana | 悬赏分：20 | 浏览次数：1856次我在公司实习 老总要求用java做oracle数据库的增删查改我现在是搞的昏头转向的，求个代码给我看看还有使用什么工具也顺便说下，谢谢大家了！2008-9-2 15:23 满意回答 用eclipse 首先在oracle文件下找到jdbc文件，里面的lib文件下有个class12.zip 在eclipse里新建个项目，建好后在左边右击那个项目图标，选择属性（最下面的），里面有个java build path，点进去，找到add external jars按键，点一下，把那个class12.zip加载进来，然后可以开始写代码了。 我的代码如下： import java.sql.*; public class connect /* * param args */ public static void main(String args) / TODO Auto-generated method stub try Class.forName(oracle.jdbc.driver.OracleDriver); catch(ClassNotFoundException e) / TODO Auto-generated catch block e.printStackTrace(); Connection con = null; Statement stmt = null; ResultSet rs = null; try String url=jdbc:oracle:thin:服务器ip地址:端口号:数据库名字; String user=用户名; String password=密码; String str=INSERT INTO ZZZ_2 VALUES(041110018,JHDK); con = java.sql.DriverManager.getConnection(url,user,password); / 创建状态 stmt = con.createStatement(); / 执行SQL语句，返回结果集 /int rowcount = stmt.executeUpdate(str); int j = stmt.executeUpdate(update ZZZ_2 set NAME=dbt where ID=21); int k = stmt.executeUpdate(delete from ZZZ_2 where ID=41110020); rs = stmt.executeQuery(SELECT * FROM ZZZ_2); / 对结果集进行处理 while (rs.next() int id = rs.getInt(ID); String name = rs.getString(NAME); /Integer age = rs.getObject(age) = null ? null : rs.getInt(age); System.out.println(id + : + name); catch(SQLException e) e.printStackTrace(); / 释放资源 finally try rs.close(); catch(SQLException e) / TODO Auto-generated catch block e.printStackTrace(); try stmt.close(); catch(SQLException e) / TODO Auto-generated catch block e.printStackTrace(); try con.close(); catch(SQLException e) / TODO Auto-generated catch block e.printStackTrace(); 注意,上面的ip地址什么的要填对,ZZZ_2是我随便建的表,你改成自己的表名就行了赞同8| 评论(1) 向TA求助 回答者： mumumomo731 | 二级 擅长领域： 出国/留学 院校信息 历史话题 程序设计 英语翻译 参加的活动： 暂时没有参加的活动 相关内容 2011-12-2 设计一张user表，表中数据user_id,username,password等参数，用jav. 2011-6-17 我使用struts1.2+spring2.0+hibernate3.1做了一个对Oracle数据库bl. 2010-8-10 java如何使用cmd命令进行oracle数据库备份 1 2011-2-26 刚进公司领导叫我用flex+java+tomcat+oracle做一个具有增删改查的. 2009-4-7 跪求基于oracle+servlet+java+jdk 的单表增删改查！ 更多关于java oracle 更新 记录的问题 查看同主题问题： oracle 数据库 java oracle oracle数据库:使用 oracle数据库:开发 oracle数据库:入门 oracle数据库:连接 2012-2-2在ubuntu下如何使用oracle sql developer创建数据库 着急谢谢了！1 2012-1-28我要学习使用oracle数据库， 是下载破解版本还是试用版？ 还是说有提. 2012-1-24Java与Oracle数据库如何连接，怎么使用相关的数据库操作语言，与C中. 2011-12-25oracle 数据库首次使用登陆问题。 2012-1-4使用 Crystal_Repor11访问64位Oracle11数据库时报错更多关于oracle数据库:使用的问题其他回答 共1条 2008-9-2 12:19 ww131219 | 四级 用eclipsepublic class Text public static final void main(String args) Connection con = null; try /1,加载驱动程序 Class.forName(oracle.jdbc.driver.OracleDriver); /2,连接字符串 String s = jdbc:oracle:thin:localhost:1521:shitou; /3,获得数据库连接 con = DriverManager.getConnection(s,system,abc); /4,获得语句对象 Statement stat = con.createStatement(); /5,执行sql ResultSet rs = stat.executeQuery(select * from comp); /查数据对人员表TUser的业务逻辑： package bean; import java.sql.*; import java.util.ArrayList; import bean.UserBean; import bean.DBUtil; public class UserDAO public UserDAO() /*更新数据，通过传递许更新的对象以及SQL语句，对数据进行添加、删除或更新操作 *obj为实体类的对象，sql为SQL语句 */ public boolean insertUser(UserBean ub) boolean b=false; Connection conn=null; PreparedStatement stmt=null; String sql=null; try /插入一条记录 sql=insert into TUser values(user_sequence.nextval,?,?,?,?,?); /创建一个连接 conn=DBUtil.getConnection(); /创建PreparedStatement的对象 stmt=conn.prepareStatement(sql); /给SQL语句内的？赋值 /stmt.setInt(1,ub.getUser_ID(); stmt.setString(1,ub.getMobile_Number(); stmt.setString(2,ub.getRoaming_Status(); stmt.setString(3,ub.getCom_Level(); stmt.setInt(4,ub.getCustomer_ID(); stmt.setInt(5,ub.getAccount_ID(); /返回执行更新操作后受影响的行数 int rst=stmt.executeUpdate(); if(rst!=0) b=true; /关闭相关的连接 DBUtil.closeStatement(stmt); DBUtil.closeConnection(conn); catch(SQLException se) se.printStackTrace(); catch(Exception e) e.printStackTrace(); return b; /*修改一条数据 *直接调用insertUser()方法 */ public boolean updateUser(UserBean ub) boolean b=false; Connection conn=null; PreparedStatement stmt=null; String sql=null; try /插入一条记录 sql=update TUser set Mobile_Number=?,Roaming_Status=?,Com_Level=?,Customer_ID=?,Account_ID=? where User_ID=+ub.getUser_ID(); /创建一个连接 conn=DBUtil.getConnection(); /创建PreparedStatement的对象 stmt=conn.prepareStatement(sql); /给SQL语句内的？赋值 /stmt.setInt(1,ub.getUser_ID(); stmt.setString(1,ub.getMobile_Number(); stmt.setString(2,ub.getRoaming_Status(); stmt.setString(3,ub.getCom_Level(); stmt.setInt(4,ub.getCustomer_ID(); stmt.setInt(5,ub.getAccount_ID(); /返回执行更新操作后受影响的行数 int rst=stmt.executeUpdate(); if(rst!=0) b=true; /关闭相关的连接 DBUtil.closeStatement(stmt); DBUtil.closeConnection(conn); catch(SQLException se) se.printStackTrace(); catch(Exception e) e.printStackTrace(); return b; /*删除一条记录 *返回boolean类型的标志，通过传递UserBean的实例对象，得到该对象的User_ID */ public boolean deleteUser(UserBean ub) boolean b=false; /测试变量，无实在意义 Connection conn=null; Statement stmt=null; String sql=null; int id=0; try id=ub.getUser_ID(); /删除记录为id的记录 sql=delete from TUser where User_ID=+id; /创建一个连接 conn=DBUtil.getConnection(); /创建PreparedStatement的对象 stmt=conn.createStatement(); /检测删除的对象是否存在 if(getUser(id)!=null&getUser(id).getUser_ID()=id) /返回执行更新操作后受影响的行数 int rst = stmt.executeUpdate(sql); if (rst 0) b = true; else System.out.println(此条记录不存在！); /关闭相关的连接 DBUtil.closeStatement(stmt); DBUtil.closeConnection(conn); /捕获异常 catch(SQLException se) se.printStackTrace(); catch(Exception e) e.printStackTrace(); return b; /*查询数据/得到数据 *str为数据库对应的列名，sql为传入的SQL语句 */ public UserBean getUser(int user_id) Connection conn=null; Statement stmt=null; ResultSet rs=null; String sql=null; UserBean user=null; try /从数据库中查询User_ID值为user_id的记录 sql=select * from TUser where User_ID=+user_id; /创建一个连接 conn=DBUtil.getConnection(); /创建Statement的对象 stmt=conn.createStatement(); /实例化UserBean的一个对象 user =new UserBean(); /执行操作，返回一个结果集 rs=stmt.executeQuery(sql); /从结果集中读取一条记录，并且将对应的属性值赋值给user if(rs.next() /System.out.println(rs.getString(User_Address); user.setUser_ID(rs.getInt(User_ID); user.setMobile_Number(rs.getString(Mobile_Number); user.setRoaming_Status(rs.getString(Roaming_Status); user.setCom_Level(rs.getString(Com_Level); user.setCustomer_ID(rs.getInt(Customer_ID); user.setAccount_ID(rs.getInt(Account_ID); /System.out.println(user.getUser_ID(); /关闭相关的连接 DBUtil.closeResultSet(rs); DBUtil.closeStatement(stmt); DBUtil.closeConnection(conn); /捕获异常 catch(SQLException se) se.printStackTrace(); catch(Exception e) e.printStackTrace(); /返回user对象 / System.out.println(user.getUser_ID(); return user; /*查询数据 *str为数据库对应的列名，sql为传入的SQL语句 *返回一个数据列表 */ public ArrayList getUsers() Connection conn=null; Statement stmt=null; ResultSet rs=null; String sql=null; UserBean user=null; ArrayList list=null; try /从数据库中查询User_ID值为user_id的记录 sql=select * from TUser; /创建一个连接 conn=DBUtil.getConnection(); /创建Statement的对象 stmt=conn.createStatement(); list=new ArrayList(); /执行操作，返回一个结果集 rs=stmt.executeQuery(sql); /从结果集中循环读取记录，并且将对应的属性值赋值给user while(rs.next() /实例化UserBean的一个对象 user =new UserBean(); user.setUser_ID(rs.getInt(User_ID); user.setMobile_Number(rs.getString(Mobile_Number); user.setRoaming_Status(rs.getString(Roaming_Status); user.setCom_Level(rs.getString(Com_Level); user.setCustomer_ID(rs.getInt(Customer_ID); user.setAccount_ID(rs.getInt(Account_ID); /将user添加到list中 list.add(user); /关闭相关的连接 DBUtil.closeResultSet(rs); DBUtil.closeStatement(stmt); DBUtil.closeConnection(conn); /捕获异常 catch(SQLException se) se.printStackTrace(); catch(Exception e) e.printStackTrace(); /返回list对象 return list; *与数据库的连接类DBUtil： package bean; import java.sql.*; public class DBUtil static String serverName=localhost; /主机地址 static String sDBDriver=oracle.jdbc.driver.OracleDriver; /oracle驱动 static String dbInstance=cloud; /数据库的名称 static String sConnStr=jdbc:oracle:thin:+serverName+:1521:+dbInstance; /数据库的连接字符串 static String dbUser=system; /数据库的登陆名 static String userPwd=manager; /数据库的登陆密码 /* *得到一个Connection对象 *return java.sql.Connection */ public static Connection getConnection() Connection conn=null; try Class.forName(sDBDriver); conn=DriverManager.getConnection(sConnStr,dbUser,userPwd); catch(ClassNotFoundException e) e.printStackTrace(); catch(SQLException se) se.printStackTrace(); return conn; /关闭指定的结果集rs public static void closeResultSet(ResultSet rs) if(rs!=null) try rs.close(); catch(SQLException e) e.printStackTrace(); /关闭指定的Statement public static void closeStatement(Statement stmt) if(stmt!=null) try stmt.close(); catch(SQLException e) e.printStackTrace(); /关闭连接conn public static void closeConnection(Connection conn) if(conn!=null) try conn.close(); catch(SQLException e) e.printStackTrace(); 自己不想写，网上这样的内容太多，自己找一下 我写了一个连接Oracle数据库测试Update的java类，但是主管要求我顺便写一个计数器，去返回130标签：oracle,数据库测试,updatejava 我写了一个连接Oracle数据库测试Update的java类，但是主管要求我顺便写一个计数器，去返回Update成功更新的数量.各位大神，求解啊，要怎么写？ 问题补充2011-10-11 16:37要求写个简单的实例出来？我追加50分爱德大师 回答:1 人气:1 解决时间:2011-10-11 16:47 满意答案好评率：0% int i = Statement.executeUpdate (sql)executeUpdate 的返回值是一个整数，指示受影响的行数（即更新计数）回答人的补充 2011-10-11 16:42 import java.sql.Connection;import java.sql.DriverManager;im