本教程的目的是使用Java編寫的分離的層去訪問數據庫中的表，這一層通常稱為數據訪問層（DAL）
使用DAL的最大好處是通過直接使用一些類似insert()和find()的方法簡化了數據庫的訪問操作，而不是總是先做鏈接，再執行一些查詢。
該層在其內部處理所有與數據庫相關的調用和查詢。
創建數據庫
我們希望為用戶創造一個簡單的表，我們可以使用這些字段來創建
id int
name varchar(200)
password varchar(200)
age int
數據傳輸對象
這一層應該包含一個簡單的類叫做數據傳輸對象（DTO）。這個類僅僅是一個與數據庫中的表相對應的簡單映射，表中的每一列對應類的一個成員變量。
我們的目的是使用簡單的Java對象，而不是處理SQL語句和其他與數據庫相關的命令來進行數據庫的增刪改查。
我們想要把表映射成java代碼，只需要創建包含相同字段的類（bean）即可
為了更好地封裝，除了構造函數我們應該聲明所有字段變量為私有，創造訪問器（getter和setter），其中有一個是默認的構造函數。
public class User { private Integer id; private String name; private String pass; private Integer age;}為了正確地映射字段，我們應該考慮數據庫中的NULL值。對於Java的原始的默認值，例如int類型，其默認值是0，所以我們應該提供可容納空值的新的數據類型。我們可以通過使用特殊的類型――封裝類，如Integer來代替INT。
最後我們的類應該像這樣：
public class User { private Integer id; private String name; private String pass; private Integer age; public User() { } public User(String name, String pass, Integer age) { this.name = name; this.pass = pass; this.age = age; } public User(Integer id, String name, String pass, Integer age) { this.id = id; this.name = name; this.pass = pass; this.age = age; } public Integer getAge() { return age; } public void setAge(Integer age) { this.age = age; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getPass() { return pass; } public void setPass(String pass) { this.pass = pass; }}一個好的做法是，提供默認的空構造函數，一個完整的構造函數和一個沒有id參數的完整構造函數。
連接數據庫
我們可以使用一個中間類來方便連接到數據庫，在這個類中，我們將提供數據庫的連接參數如數據庫JDBC， URL，用戶名和密碼，並將這些變量定義成final的（從properties 或者xml配置文件中獲取這些數據將會更好）
提供一個方法返回一個Connection對像或者當連接失敗時返回一個null又或者拋出一個運行時異常。
public static final String URL = "jdbc:mysql://localhost:3306/testdb";public static final String USER = "testuser";public static final String PASS = "testpass";/** * 獲取connection對象* @return Connection 對象*/public static Connection getConnection() { try { DriverManager.registerDriver(new Driver()); return DriverManager.getConnection(URL, USER, PASS); } catch (SQLException ex) { throw new RuntimeException("Error connecting to the database", ex); }}我們也可以在類中包含一個主方法來測試連接。完整的類像這樣：
import com.mysql.jdbc.Driver;import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException;/** * Connect to Database * @author hany.said */public class ConnectionFactory { public static final String URL = "jdbc:mysql://localhost:3306/testdb"; public static final String USER = "testuser"; public static final String PASS = "testpass"; /** * Get a connection to database * @return Connection object */ public static Connection getConnection() { try { DriverManager.registerDriver(new Driver()); return DriverManager.getConnection(URL, USER, PASS); } catch (SQLException ex) { throw new RuntimeException("Error connecting to the database", ex); } } /** * Test Connection */ public static void main(String[] args) { Connection connection = connectionFactory.getConnection(); }}數據訪問對象
DAO層可以做CRUD操作。它可以對我們的表進行增刪改查。
我們的DAO層接口應該像這樣：
public interface UserDao { User getUser(); Set<User> getAllUsers(); User getUserByUserNameAndPassword(); boolean insertUser(); boolean updateUser(); boolean deleteUser();}查找用戶
用戶可以通過像ID，姓名或郵箱等任何唯一字段來查詢。在這個例子中，我們使用ID來查找用戶。第一步是通過連接器類來創建一個connection，然後執行SELECT語句以獲得其ID為7的用戶，我們可以使用這條語句查詢用戶：
SELECT * FROM user WHERE id=7
就在這裡，我們做了一個動態的語句來從參數中獲取ID。
通過執行這個查詢，得到一個結果集，其中保存有用戶或null。我們可以通過Resultset的next()方法來檢測是否有值。如果返回true，我們將繼續利用data getters從ResultSet中獲取用戶數據。當我們將所有的數據封裝到user中後，我們返回它。如果不存在此ID的用戶或其他任何異常發生（如無效的SQL語句）這個方法會返回null。
public User getUser(int id) { Connection connection = connectionFactory.getConnection(); try { Statement stmt = connection.createStatement(); ResultSet rs = stmt.executeQuery("SELECT * FROM user WHERE id=" + id); if(rs.next()) { User user = new User(); user.setId( rs.getInt("id") ); user.setName( rs.getString("name") ); user.setPass( rs.getString("pass") ); user.setAge( rs.getInt("age") ); return user; } } catch (SQLException ex) { ex.printStackTrace(); } return null;}使用單獨的方法來從結果集中提取數據將會更方便，因為在很多方法中我們將會調用它。
這個新方法將拋出SQLException並且為了限制只能在類內部使用，其應該是私有的：
private User extractUserFromResultSet(ResultSet rs) throws SQLException { User user = new User(); user.setId( rs.getInt("id") ); user.setName( rs.getString("name") ); user.setPass( rs.getString("pass") ); user.setAge( rs.getInt("age") ); return user;}我們上面的方法應該修改成新的方法：
public User getUser(int id) { Connection connection = connectionFactory.getConnection(); try { Statement stmt = connection.createStatement(); ResultSet rs = stmt.executeQuery("SELECT * FROM user WHERE id=" + id); if(rs.next()) { return extractUserFromResultSet(rs); } } catch (SQLException ex) { ex.printStackTrace(); } return null;}登陸方法
登陸操作類似。我們希望提供用戶和密碼替代ID，這將不會影響參數列表和查詢語句。如果用戶名和密碼是正確的，這個方法會返回一個有效的用戶，否則為null。因為有很多的參數，使用PreparedStatement將更有用。
public User getUserByUserNameAndPassword(String user, String pass) { Connector connector = new Connector(); Connection connection = connector.getConnection(); try { PreparedStatement ps = connection.prepareStatement("SELECT * FROM user WHERE user=? AND pass=?"); ps.setString(1, user); ps.setString(2, pass); ResultSet rs = ps.executeQuery(); if(rs.next()) { return extractUserFromResultSet(rs); } } catch (SQLException ex) { ex.printStackTrace(); } return null;}查詢所有用戶的方法
這個方法將會返回所有的用戶，所以我們應該將它們存在一個類似數組的容器中返回來。但是，因為我們不知道有多少條記錄。 使用例如Set或者List的集合將會更好：
public Set getAllUsers() { Connector connector = new Connector(); Connection connection = connector.getConnection(); try { Statement stmt = connection.createStatement(); ResultSet rs = stmt.executeQuery("SELECT * FROM user"); Set users = new HashSet(); while(rs.next()) { User user = extractUserFromResultSet(rs); users.add(user); } return users; } catch (SQLException ex) { ex.printStackTrace(); } return null;}插入方法
Insert方法將採取用戶作為參數，並使用PreparedStatement對象來執行SQL update語句。 executeUpdate 方法返回受影響的行數。如果我們添加單行，意味著該方法應該返回1，如果是這樣，我們返回true，否則，我們返回false
public boolean insertUser(User user) { Connector connector = new Connector(); Connection connection = connector.getConnection(); try { PreparedStatement ps = connection.prepareStatement("INSERT INTO user VALUES (NULL, ?, ?, ?)"); ps.setString(1, user.getName()); ps.setString(2, user.getPass()); ps.setInt(3, user.getAge()); int i = ps.executeUpdate(); if(i == 1) { return true; } } catch (SQLException ex) { ex.printStackTrace(); } return false;}更新方法
更新方法和插入方法類似。唯一變化的是SQL語句
public boolean updateUser(User user) { Connector connector = new Connector(); Connection connection = connector.getConnection(); try { PreparedStatement ps = connection.prepareStatement("UPDATE user SET name=?, pass=?, age=? WHERE id=?"); ps.setString(1, user.getName()); ps.setString(2, user.getPass()); ps.setInt(3, user.getAge()); ps.setInt(4, user.getId()); int i = ps.executeUpdate(); if(i == 1) { return true; } } catch (SQLException ex) { ex.printStackTrace(); } return false;}刪除方法
刪除的方法是使用一個簡單的查詢像
DELETE FROM user WHERE ID = 7
帶上id參數發送該查詢將刪除此記錄。如果成功刪除將返回1
public boolean deleteUser(int id) { Connector connector = new Connector(); Connection connection = connector.getConnection(); try { Statement stmt = connection.createStatement(); int i = stmt.executeUpdate("DELETE FROM user WHERE id=" + id); if(i == 1) { return true; } } catch (SQLException ex) { ex.printStackTrace(); } return false;}感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！