如何使用MySQL和Java实现一个简单的电影推荐功能
近年来,随着互联网和大数据的普及,电影推荐功能成为很多影视平台的重要组成部分。通过分析用户的喜好和行为,可以精准地推荐给用户适合的电影,提升用户体验和平台的活跃度。本文将介绍如何使用MySQL和Java实现一个简单的电影推荐功能,并提供具体的代码示例。
- 数据库设计
在开始之前,我们需要设计一个数据库来存储电影和用户的数据。假设电影有id、名称、类型、评分等字段,用户有id、用户名等字段。此外,我们还需要设计一个表来存储用户的观影记录,包括用户id、电影id和观影时间等字段。具体的SQL语句如下:
-- 创建电影表
CREATE TABLE movies (
id INT PRIMARY KEY AUTO_INCREMENT,
name VARCHAR(255),
type VARCHAR(255),
rating DECIMAL(3,1)
);
-- 创建用户表
CREATE TABLE users (
id INT PRIMARY KEY AUTO_INCREMENT,
username VARCHAR(255)
);
-- 创建观影记录表
CREATE TABLE user_movie_records (
user_id INT,
movie_id INT,
watch_time DATETIME,
PRIMARY KEY(user_id, movie_id),
FOREIGN KEY(user_id) REFERENCES users(id),
FOREIGN KEY(movie_id) REFERENCES movies(id)
);
- 数据库操作
使用Java语言可以连接到MySQL数据库,并进行相关的操作。下面是一个简单的示例,包括连接数据库、查询电影信息和插入观影记录三个功能:
import java.sql.*;
public class MovieRecommendationSystem {
private static final String DB_URL = "jdbc:<a style=\'color:#f60; text-decoration:underline;\' href="https://www.php.cn/zt/15713.html" target="_blank">mysql</a>://localhost:3306/movie_recommendation"; private static final String DB_USER = "root"; private static final String DB_PASSWORD = "password"; public static void main(String[] args) { try(Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD); Statement stmt = conn.createStatement()) { // 查询电影信息 String movieQuery = "SELECT * FROM movies"; ResultSet movieResult = stmt.executeQuery(movieQuery); while (movieResult.next()) { int id = movieResult.getInt("id"); String name = movieResult.getString("name"); String type = movieResult.getString("type"); double rating = movieResult.getDouble("rating"); System.out.println("电影ID:" + id + ",电影名称:" + name + ",电影类型:" + type + ",评分:" + rating); } // 插入观影记录 int userId = 1; int movieId = 1; String watchTime = "2022-01-01 08:00:00"; String insertRecord = "INSERT INTO user_movie_records (user_id, movie_id, watch_time) VALUES (?, ?, ?)"; PreparedStatement insertStmt = conn.prepareStatement(insertRecord); insertStmt.setInt(1, userId); insertStmt.setInt(2, movieId); insertStmt.setString(3, watchTime); insertStmt.executeUpdate(); System.out.println("插入观影记录成功"); } catch (SQLException e) { e.printStackTrace(); } }