dao连接mysql数据库

DAO（Data Access Object）是一种设计模式，用于将底层的数据访问逻辑与业务逻辑分离。它提供了一种抽象层，使得应用程序的其他部分不需要直接与数据库交互，而是通过DAO接口进行操作。以下是关于DAO连接MySQL数据库的基础概念、优势、类型、应用场景以及常见问题及解决方法。

基础概念

DAO模式：DAO模式是一种软件设计模式，用于将数据访问逻辑与业务逻辑分离。它通常包括一组接口和实现类，用于执行CRUD（创建、读取、更新、删除）操作。
MySQL数据库：MySQL是一种流行的关系型数据库管理系统，广泛用于Web应用程序和各种企业应用。

优势

解耦：将数据访问逻辑与业务逻辑分离，使得代码更易于维护和测试。
可重用性：DAO层可以被多个业务逻辑层复用，减少代码重复。
灵活性：更换数据库时，只需修改DAO层的实现，而不需要改动业务逻辑层。
安全性：可以在DAO层进行数据验证和安全检查，防止SQL注入等安全问题。

类型

简单DAO：直接使用JDBC进行数据库操作。
ORM DAO：使用对象关系映射（ORM）框架，如Hibernate、MyBatis等，简化数据库操作。

应用场景

Web应用程序：在Web应用中，DAO层通常用于处理HTTP请求中的数据库操作。
企业应用：在企业级应用中，DAO层用于处理复杂的业务逻辑和数据操作。
移动应用：在移动应用中，DAO层用于处理本地数据库或远程数据库的操作。

示例代码（使用JDBC连接MySQL）

1. 创建数据库连接

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

public class DatabaseConnection {
    private static final String URL = "jdbc:mysql://localhost:3306/mydatabase";
    private static final String USER = "username";
    private static final String PASSWORD = "password";

    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(URL, USER, PASSWORD);
    }
}

2. 创建DAO接口

import java.util.List;

public interface UserDao {
    User getUserById(int id);
    List<User> getAllUsers();
    void addUser(User user);
    void updateUser(User user);
    void deleteUser(int id);
}

3. 实现DAO接口

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class UserDaoImpl implements UserDao {
    @Override
    public User getUserById(int id) {
        String sql = "SELECT * FROM users WHERE id = ?";
        try (Connection conn = DatabaseConnection.getConnection();
             PreparedStatement ps = conn.prepareStatement(sql)) {
            ps.setInt(1, id);
            ResultSet rs = ps.executeQuery();
            if (rs.next()) {
                return new User(rs.getInt("id"), rs.getString("name"), rs.getString("email"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

    @Override
    public List<User> getAllUsers() {
        List<User> users = new ArrayList<>();
        String sql = "SELECT * FROM users";
        try (Connection conn = DatabaseConnection.getConnection();
             PreparedStatement ps = conn.prepareStatement(sql)) {
            ResultSet rs = ps.executeQuery();
            while (rs.next()) {
                users.add(new User(rs.getInt("id"), rs.getString("name"), rs.getString("email")));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return users;
    }

    @Override
    public void addUser(User user) {
        String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
        try (Connection conn = DatabaseConnection.getConnection();
             PreparedStatement ps = conn.prepareStatement(sql)) {
            ps.setString(1, user.getName());
            ps.setString(2, user.getEmail());
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void updateUser(User user) {
        String sql = "UPDATE users SET name = ?, email = ? WHERE id = ?";
        try (Connection conn = DatabaseConnection.getConnection();
             PreparedStatement ps = conn.prepareStatement(sql)) {
            ps.setString(1, user.getName());
            ps.setString(2, user.getEmail());
            ps.setInt(3, user.getId());
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void deleteUser(int id) {
        String sql = "DELETE FROM users WHERE id = ?";
        try (Connection conn = DatabaseConnection.getConnection();
             PreparedStatement ps = conn.prepareStatement(sql)) {
            ps.setInt(1, id);
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}