@hongfangze/database NPM

@hongfangze/database 数据库操作类

介绍

支持Mysql、Postgresql、Redis

Redis使用

 const Redis = CreateRedis({
    host: "",
    password: "",
    db: 1,
  });
  await Redis.set("a", "1");
  await Redis.set("b", "2", 10);
  let res = await Redis.get("a");
  console.log("get", res);
  res = await Redis.ttl("a");
  console.log("ttl", res);
  res = await Redis.exists("a");
  console.log("exists", res);
  res = await Redis.exists("c");
  console.log("exists", res);
  res = await Redis.exists("c");
  console.log("exists", res);
  await Redis.del("a");
  await Redis.set("hello word", "2", 10);
  res = await Redis.keys();
  console.log("keys", res);
  res = await Redis.keys("h*");
  //  res = await Redis.keys("h?llow word");
  //  res = await Redis.keys("h[eo]llow word");
  console.log("keys", res);

  await Redis.rpush("list", "1");
  await Redis.rpush("list", "2");
  await Redis.rpush("list", "3");
  while (true) {
    let list = await Redis.lpop("list");
    if (!list) {
      break;
    }
    console.log("list", list);
    await sleep(1000);
  }

const taskInstance = new Task();
  const params = new Array(100).fill('');
  taskInstance.on("process", (index, err, result: any) => {
    console.log(`第${index}个任务已经完成，返回值：`, result);
  });
  taskInstance.on("end", (results) => {
    console.log("所有任务完成，返回值：", results);
  });
  await taskInstance.start(getAutoNumber, params, 20);

async function getAutoNumber() {
  const redis = CreateRedis({
    password: ""
  });
  let number = await redis.getAutoNumber("ORDER", "YYYYMMDD", 6, "END");
  return number;
}