flex与数据库的例子 flex工程

/** * */ package flexdemo; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; /** * * */ public class EmployeeManager { /** * * @return */ public EmployeeManager(){ } public List listEmployees() { ArrayList list = new ArrayList(); Connection conn = null; try { conn = ConnectionManager.getConnection(); Statement stmt = conn.createStatement(); String sql = "select * from test"; ResultSet rs = stmt.executeQuery(sql); while (rs.next()) { Employee employee = new Employee(rs.getInt("id"), rs .getString("name"), rs.getString("email"), rs .getString("phone"), rs.getString("zipcode") ); list.add(employee); } } catch (SQLException e) { e.printStackTrace(); } finally { ConnectionManager.closeConnection(conn); } return list; } /*************************************************************************** * * * * * * @param employee */ public void addEmployee(Employee employee) { Connection conn = null; try { conn = ConnectionManager.getConnection(); String sql = "insert into test(name,email,phone,zipcode) values(?,?,?,?)"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, employee.getName()); pstmt.setString(2, employee.getEmail()); pstmt.setString(3, employee.getPhone()); pstmt.setString(4, employee.getZipcode()); pstmt.execute(); } catch (SQLException e) { e.printStackTrace(); } finally { ConnectionManager.closeConnection(conn); } } /** * * */ public void updateEmployee(Employee employee) { Connection conn = null; try { conn = ConnectionManager.getConnection(); String sql = "update test set name=? ,email=?,phone=?,zipcode=? where email='"+employee.getEmail()+"'"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, employee.getName()); pstmt.setString(2, employee.getEmail()); pstmt.setString(3, employee.getPhone()); pstmt.setString(4, employee.getZipcode()); pstmt.execute(); } catch (SQLException e) { e.printStackTrace(); } finally { ConnectionManager.closeConnection(conn); } } /** * */ public void deleteEmployee(Employee employee) { Connection conn = null; try { conn = ConnectionManager.getConnection(); String sql = "delete test where email='"+employee.getEmail()+"'"; Statement stmt = conn.createStatement(); stmt.executeUpdate(sql); } catch (SQLException e) { e.printStackTrace(); } finally { ConnectionManager.closeConnection(conn); } } }