java操作oracle常用的示例代碼

y37f 9年前發布 | 4K 次閱讀 Java

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBTools { // 定義一個方法,用來得到一個"新的"連接對象 public static Connection getConnection() { Connection conn = null; String driverName = "oracle.jdbc.driver.OracleDriver"; String url = "jdbc:oracle:thin:@localhost:1521:ora9i"; String userName = "scott"; String passWord = "tiger"; try { Class.forName(driverName); conn = DriverManager.getConnection(url,userName,passWord ); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } return conn; }

public static void closeConn(Connection conn) { try { if(conn != null) { conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } }

public static void closeState(Statement state) { try { if(state != null) { state.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } }

public static void closeRs(ResultSet rs) { try { if(rs != null) { rs.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }

import java.sql.ResultSet; import java.sql.Statement; import java.util.ArrayList;

import com.tianyitime.notebook.support.userPO.UserPO; import com.tianyitime.notebook.support.util.DBTools;

public class UserDAO {

// 新增user public void saveUserInfo(UserPO upo) { Connection conn = null; Statement state = null; try { conn = DBTools.getConnection(); state = conn.createStatement(); String sql = "insert into notebook_user values ("+getMaxId()+",'"+upo.getYhm()+"','"+upo.getEmail()+"','"+upo.getContent()+"')"; //System.out.println(sql); state.executeUpdate(sql);

} catch (Exception ex) { // TODO Auto-generated catch block ex.printStackTrace(); } finally { DBTools.closeState(state); DBTools.closeConn(conn); } }

//得到一個數據庫中當前Id的最大值 private int getMaxId() { Connection conn = null; Statement state = null; ResultSet rs = null; int maxId = 0; try { conn = DBTools.getConnection(); state = conn.createStatement(); String sql = "select max(id) maxId from notebook_user"; rs = state.executeQuery(sql); //從resultset對象中將數據取出 if(rs.next()) { maxId = rs.getInt("maxId"); } } catch (Exception ex) { // TODO Auto-generated catch block ex.printStackTrace(); }

return ++maxId; }

// 得到所有的記錄 public ArrayList getUserInfo() { Connection conn = null; Statement state = null; ResultSet rs = null; UserPO upo = null; ArrayList al = new ArrayList(); try { conn = DBTools.getConnection(); state = conn.createStatement(); String sql = "select * from notebook_user"; rs = state.executeQuery(sql); //從resultset對象中將數據取出

while(rs.next()) { upo = new UserPO(); int id = rs.getInt("id"); String yhm = rs.getString("yhm"); String email = rs.getString("email"); String content = rs.getString("content");

upo.setId(id); upo.setYhm(yhm); upo.setEmail(email); upo.setContent(content);

//將改對象放入已經創建好的集合類對象ArrauyList al.add(upo); } } catch (Exception ex) { // TODO Auto-generated catch block ex.printStackTrace(); } finally { DBTools.closeRs(rs); DBTools.closeState(state); DBTools.closeConn(conn); } return al; }

// 刪除一條user記錄 public void deleteUserInfo(int id) { Connection conn = null; Statement state = null; try { conn = DBTools.getConnection(); state = conn.createStatement(); String sql = "delete from notebook_user where id="+id; //System.out.println(sql); state.executeUpdate(sql);

} catch (Exception ex) { // TODO Auto-generated catch block ex.printStackTrace(); } finally { DBTools.closeState(state); DBTools.closeConn(conn); } }

// 根據給定的信息得到記錄 public ArrayList getUserInfoByInfo(String name,String email,String content) { Connection conn = null; Statement state = null; ResultSet rs = null; UserPO upo = null; ArrayList al = new ArrayList(); try { conn = DBTools.getConnection(); state = conn.createStatement(); String sql = "select * from notebook_user where 1=1 "; if(!"".equals(name) && name != null) { sql += " and yhm like '%"+name+"%'"; } if(!"".equals(email) && email != null) { sql += " and email = '"+email+"'"; } if(!"".equals(content) && content != null) { sql += " and content like '%"+content+"%'"; } sql+=" order by id desc"; rs = state.executeQuery(sql); //從resultset對象中將數據取出

while(rs.next()) { upo = new UserPO(); int id = rs.getInt("id"); String yhm = rs.getString("yhm"); String femail = rs.getString("email"); String fcontent = rs.getString("content");

upo.setId(id); upo.setYhm(yhm); upo.setEmail(femail); upo.setContent(fcontent);

//將改對象放入已經創建好的集合類對象ArrauyList al.add(upo); } } catch (Exception ex) { // TODO Auto-generated catch block ex.printStackTrace(); } finally { DBTools.closeRs(rs); DBTools.closeState(state); DBTools.closeConn(conn); } return al; }

}</pre>

 本文由用戶 y37f 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
 轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!