public class RedisService {

public static String server = "localhost";

public Boolean addEmployee(Employee employee) {
Jedis jedis = new Jedis(server);
}

# for unknown 
public void addDeptInfo(String key, String data) {
Jedis jedis = new Jedis(RedisProperties.connection);
jedis.set(key, data);
}

}

public static void main(String[] args) {
        RedisClient client = RedisClient.create("redis://localhost");
        StatefulRedisConnection<String, String> connection = client.connect();
        
        RedisHashCommands<String, String> hashCommands = connection.sync().commands();
        
        KeyValueStreamingChannel<String, String> channel = new KeyValueStreamingChannel<String, String>() {
            @Override
            public void onKeyValue(String key, String value) {
                System.out.println(key + " => " + value);
            }
        };
}

//adding employee in a redis list
public Boolean addEmployee(Employee employee) {
    Jedis jedis = new Jedis(server);
    Employee emp = new Employee();
    emp=getEmployee(employee.getEmployeeId());
    jedis.lpush("employeelist", employee.toString());
    return true;
}
 
 
//add departments in a set
public void addDept(String dept) {
    Jedis jedis = new Jedis(server);
    jedis.sadd("departments", dept);
}

// Inserts field=value to myhash
public void set_operation(RedisHashCommands hashCommands){
	hashCommands.hset("myhash", "field1", "value1");
    hashCommands.hset("myhash", "field2", "value2");
    hashCommands.hset("myhash", "field3", "value3");
}

//get all employees from employee list
public List<Employee> getAllEmployee(){
    List<Employee> employeeList = new ArrayList<>();
    Jedis jedis = new Jedis(server);
    List<String> employees = jedis.lrange("employeelist", 0, jedis.llen("employeelist"));
    for (String employee: employees) {
        String[] emp1=employee.split(",");
        Employee emp = new Employee(Integer.parseInt(emp1[0]), emp1[1], emp1[2]);
        employeeList.add(emp);
    }
    return employeeList;
}
 
 
//get all departments from set
public Set<String> getDepts() {
    Jedis jedis = new Jedis(server);
    return jedis.smembers("departments");
}

// retrieves all the data from myhash
public void get_operation(RedisHashCommands hashCommands, KeyValueStreamingChannel channel){
	hashCommands.hgetall(channel, "myhash");
}

// delete first visitor from visitors set
public Visitor deleteVisitor() {
    Jedis jedis = new Jedis(server);
    Map<String,Integer> visitors = get_Visitors();
    Visitor vis = new Visitor();
    for (Map.Entry<String, Integer> visitor : visitors.entrySet()) {
        vis.setName(visitor.getKey());
        vis.setId(jedis.zscore("visitors", visitor.getKey()));
        break;
    }
    jedis.zrem("visitors", vis.getName());
    return vis;
}
 
//delete department information from cache
public String deleteDeptInfo(String key) {
    Jedis jedis = new Jedis(server);
    String value = jedis.get(key);
    jedis.del(key);
    return key + " = " + value + " successfully deleted";
}

// Deletes field3 and field4 from myhash
public void del_operation(RedisHashCommands hashCommands){
	hashCommands.hdel("myhash", "field3", "field4");
}

public class Example {
	public static void main(String[] args) {
	// Create a new Jedis instance connected to Redis
	Jedis jedis = new Jedis("localhost");

	// Set the initial value of a key "mycounter" to 10
	jedis.set("mycounter", "10");

	// Decrement the value of "mycounter" by 3 using decrBy method
	Long newCounterValue = jedis.decrBy("mycounter", 3);

	// Retrieving the elements of mycounter
	System.out.println("Elements in mycounter: " + jedis.smembers("mycounter"));

	// Close the Jedis instance
	jedis.close();
	}
}

// Updates myhash field4 by 10
public void update_operation(RedisHashCommands hashCommands){
	hashCommands.hincrby("myhash", "field4", 10);
}

void set_value(){
		// Add some fields to the hash
        transaction.hset("myhash", "field1", "3");
        transaction.hset("myhash", "field2", "2");
        transaction.hset("myhash", "field3", "3");
        
        // Execute the transaction
        transaction.exec_();
		
    }	

   void get_value() {
		// Retrieve the values after the transaction
		System.out.println(transaction.hget("myhash", "field1"));
	}

void del_value() {
// Perform hdel operation within a transaction
transaction.hdel("myhash", "field3");

// Execute the transaction
transaction.exec_();
}

void incr_value() {
		// Perform hincrBy operation within a transaction
        transaction.hincrBy("myhash", "field1", 5);
        
        // Execute the transaction
        transaction.exec_();
		
}

public void set_operation(RedisHashCommands hashCommands){
        hashCommands.hset("myhash", "field1", "value1");
        hashCommands.hset("myhash", "field2", "value2");
        hashCommands.hset("myhash", "field3", "value3");
}

    

public void get_operation(RedisHashCommands hashCommands, KeyValueStreamingChannel channel){
        hashCommands.hgetall(channel, "myhash");
} 

public void del_operation(RedisHashCommands hashCommands){
        hashCommands.hdel("myhash", "field3", "field4");
}

public void update_operation(RedisHashCommands hashCommands){
        hashCommands.hincrby("myhash", "field4", 10);
}