Redis ক্যাশিং

mkdir node-redis-crud
cd node-redis-crud
npm init -y

npm install typeorm mysql2 redis

{
  "type": "mysql",
  "host": "localhost",
  "port": 3306,
  "username": "root",
  "password": "password",
  "database": "test",
  "entities": ["./src/entities/*.js"],
  "synchronize": true
}

const redis = require('redis');
const redisClient = redis.createClient(); // Redis ক্লায়েন্ট তৈরি করা

redisClient.on('error', (err) => {
    console.error('Redis ত্রুটি:', err); // Redis ত্রুটি লোগ করা
});

module.exports = redisClient; // Redis ক্লায়েন্ট এক্সপোর্ট করা

const { EntitySchema } = require('typeorm');

module.exports = new EntitySchema({
    name: 'User',
    tableName: 'users',
    columns: {
        id: {
            type: 'int',
            primary: true,
            generated: true,
        },
        username: {
            type: 'varchar',
            unique: true,
            nullable: false,
        },
        email: {
            type: 'varchar',
            unique: true,
            nullable: false,
        },
        password: {
            type: 'varchar',
            nullable: false,
        },
    },
});

const { getRepository } = require('typeorm'); // TypeORM থেকে getRepository ফাংশন ইম্পোর্ট করা
const User = require('../entities/User');     // User entity ইম্পোর্ট করা
const redisClient = require('../utils/redisClient'); // Redis ক্লায়েন্ট ইম্পোর্ট করা

// ব্যবহারকারী আইডি দিয়ে ব্যবহারকারী তথ্য নেওয়া
const getUserById = async (id) => {
    const cacheKey = `user:${id}`;  // ক্যাশে কী তৈরি করা (যেমন: user:1)

    // Redis ক্যাশে ব্যবহারকারী ডেটা আছে কিনা পরীক্ষা করা
    let user = await redisClient.get(cacheKey);

    if (user) {
        console.log('Redis ক্যাশ থেকে সার্ভিং হচ্ছে'); // ক্যাশে পাওয়া গেলে লগ করা
        return JSON.parse(user); // ক্যাশ থেকে পাওয়া JSON ডেটা পার্স করে ফেরত দেয়া
    }

    // যদি ক্যাশে না পাওয়া যায়, তাহলে ডেটাবেস থেকে ডেটা নিয়ে আসা
    const userRepository = getRepository(User); // User repository পাওয়া
    user = await userRepository.findOne(id); // ডেটাবেস থেকে নির্দিষ্ট আইডি দিয়ে ব্যবহারকারী খুঁজে পাওয়া

    if (user) {
        // Redis ক্যাশে ফলাফল সংরক্ষণ করা
        await redisClient.set(cacheKey, JSON.stringify(user), 'EX', 3600);  // ১ ঘণ্টা (3600 সেকেন্ড) ক্যাশে রাখা
    }

    return user; // ব্যবহারকারী ডেটা ফেরত দেয়া
};

// নতুন ব্যবহারকারী তৈরি করা
const createUser = async (username, email, password) => {
    const userRepository = getRepository(User); // User repository পাওয়া
    const user = userRepository.create({ username, email, password }); // নতুন ব্যবহারকারী তৈরি করা
    await userRepository.save(user); // ব্যবহারকারী ডেটাবেসে সেভ করা

    // ক্যাশে নতুন ব্যবহারকারী সংরক্ষণ করা
    const cacheKey = `user:${user.id}`;
    await redisClient.set(cacheKey, JSON.stringify(user), 'EX', 3600); // ক্যাশে রাখা

    return user; // নতুন ব্যবহারকারী ফেরত দেয়া
};

// ব্যবহারকারী আপডেট করা
const updateUser = async (id, updateData) => {
    const userRepository = getRepository(User); // User repository পাওয়া
    let user = await userRepository.findOne(id); // ব্যবহারকারী খুঁজে পাওয়া

    if (user) {
        // আপডেট করা
        user = { ...user, ...updateData };
        await userRepository.save(user); // ডেটাবেসে আপডেট করা

        // ক্যাশে নতুন ডেটা আপডেট করা
        const cacheKey = `user:${id}`;
        await redisClient.set(cacheKey, JSON.stringify(user), 'EX', 3600); // ক্যাশে রাখা
    }

    return user; // আপডেটকৃত ব্যবহারকারী ফেরত দেয়া
};

// ব্যবহারকারী মুছে ফেলা
const deleteUser = async (id) => {
    const userRepository = getRepository(User); // User repository পাওয়া
    const user = await userRepository.findOne(id); // ব্যবহারকারী খুঁজে পাওয়া

    if (user) {
        await userRepository.remove(user); // ব্যবহারকারী ডেটাবেস থেকে মুছে ফেলা

        // ক্যাশে ডেটা মুছে ফেলা
        const cacheKey = `user:${id}`;
        await redisClient.del(cacheKey); // ক্যাশে থেকে মুছে ফেলা
    }

    return user; // মুছে ফেলা ব্যবহারকারী ফেরত দেয়া
};

module.exports = {
    getUserById,
    createUser,
    updateUser,
    deleteUser
};

const { createConnection } = require('typeorm'); // TypeORM থেকে createConnection ইম্পোর্ট করা
const { getUserById, createUser, updateUser, deleteUser } = require('./crud/userCrud'); // CRUD ফাংশন ইম্পোর্ট করা

const start = async () => {
    // ডেটাবেসে সংযোগ তৈরি করা
    await createConnection();

    // কিছু অপারেশন পরীক্ষা করা
    const newUser = await createUser('john_doe', 'john@example.com', 'password123');
    console.log('নতুন ব্যবহারকারী:', newUser);

    const user = await getUserById(newUser.id);
    console.log('ব্যবহারকারী তথ্য:', user);

    const updatedUser = await updateUser(newUser.id, { password: 'newpassword123' });
    console.log('আপডেটকৃত ব্যবহারকারী:', updatedUser);

    const deletedUser = await deleteUser(newUser.id);
    console.log('মুছে ফেলা ব্যবহারকারী:', deletedUser);
};

start();