标签 Javascript 下的文章

2024-09-02

在SQLite中，你可以使用内置的 json_each 函数来遍历 JSON 数组，并使用 like 或 in 关键字来判断数组是否包含某个元素。以下是一个例子：

假设我们有一个名为 data 的表，其中有一个名为 json_column 的列，该列包含 JSON 数组。我们想要找出那些 JSON 数组中包含数字 1 的行。




SELECT *
FROM data
WHERE '1' IN (SELECT json_each.value
              FROM json_each(json_column)
              WHERE json_each.value = '1');

这个查询会返回所有 json_column 字段中包含数字 1 的行。

如果你的 SQLite 版本低于 3.35.0，不支持 json_each 函数，你可以使用 json_extract 函数结合 like 关键字来实现：




SELECT *
FROM data
WHERE '["1"]' LIKE '%,"1",%';

这个查询假设 JSON 数组元素都是独立的，并且没有任何逗号在元素周围，这可能不适用于所有情况，因为它对 JSON 数组元素的格式有严格的假设。

- 阅读更多 -

Nodejs(Koa)-Redis集成及基础使用

System

2024-09-01

所有,redis




const Koa = require('koa');
const redis = require('redis');
const { promisify } = require('util');
 
// 创建Koa应用
const app = new Koa();
 
// 创建Redis客户端
const redisClient = redis.createClient({
  url: 'redis://localhost:6379'
});
 
// 将Redis客户端的各个异步方法转换为Promise版本
const getAsync = promisify(redisClient.get).bind(redisClient);
const setAsync = promisify(redisClient.set).bind(redisClient);
 
// 中间件：处理GET请求并操作Redis
app.use(async (ctx) => {
  if (ctx.request.method === 'GET') {
    const key = 'my_key';
    const value = await getAsync(key); // 异步获取key的值
    ctx.body = value || 'No value found';
 
    if (!value) {
      await setAsync(key, 'initial_value'); // 如果没有值，设置初始值
    }
  }
});
 
// 启动服务
app.listen(3000, () => {
  console.log('Server is running on port 3000');
});

这段代码创建了一个简单的Koa服务器，并集成了Redis客户端。它演示了如何使用Promise来简化异步代码，并处理了GET请求，从Redis中获取键对应的值，如果没有找到值，它还会设置一个初始值。这个例子是学习如何在Node.js中使用Koa和Redis的一个很好的起点。

System

2024-09-01

所有,redis

由于这个项目涉及的内容较多且涉及到个人隐私和商业利益，我无法提供完整的代码。但我可以提供一个简化的框架代码示例，说明如何实现一个基本的用户模块。




// UserController.java (Spring MVC Controller)
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
 
@Controller
@RequestMapping("/user")
public class UserController {
 
    // 假设这里注入了UserService
    private UserService userService;
 
    @RequestMapping(value = "/register", method = RequestMethod.POST)
    public @ResponseBody String registerUser(@RequestParam String username,
                                             @RequestParam String password) {
        // 调用服务层的方法来注册用户
        boolean success = userService.register(username, password);
        return success ? "注册成功" : "注册失败";
    }
 
    // ... 其他用户操作，如登录、查找用户信息等
}
 
// UserService.java (Spring Service)
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
@Service
public class UserService {
 
    @Autowired
    private UserRepository userRepository; // 假设这是Spring Data JPA的Repository
 
    public boolean register(String username, String password) {
        // 在这里可以添加更多的验证逻辑
        User user = new User();
        user.setUsername(username);
        user.setPassword(password); // 这里应当处理密码的安全存储，例如使用BCrypt
        userRepository.save(user);
        return true;
    }
 
    // ... 其他用户操作方法
}
 
// User.java (实体类)
public class User {
    private Long id;
    private String username;
    private String password;
 
    // 省略getter和setter方法
}

这个简化的框架代码展示了如何在一个Java Web项目中使用Spring框架来创建一个用户注册功能。在实际的项目中，你需要配置数据库连接、事务管理、安全性等方面的细节。这个例子只是展示了如何在后端框架中定义一个简单的用户注册功能，并未包含完整的系统实现。

System

2024-09-01

所有,java

在JSP页面中，我们可以使用表单（form）来提交用户输入的数据。以下是一个简单的例子，展示了如何添加一个用于添加商品的表单：




<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
<head>
    <title>添加商品</title>
</head>
<body>
    <h1>添加商品</h1>
    <form action="addProduct" method="post">
        <label for="productName">商品名称:</label>
        <input type="text" id="productName" name="productName" required><br><br>
        <label for="productPrice">商品价格:</label>
        <input type="number" id="productPrice" name="productPrice" required><br><br>
        <label for="productDesc">商品描述:</label>
        <input type="text" id="productDesc" name="productDesc" required><br><br>
        <input type="submit" value="提交">
    </form>
</body>
</html>

在这个表单中，我们定义了三个输入字段：商品名称、商品价格和商品描述。表单的action属性应该指向一个Servlet或者其他的JSP页面，用于处理表单提交的数据。method属性设置为post，因为这种方法可以发送更多的数据，并且对用户来说是不可见的。

在后端，你需要创建一个Servlet来处理这些数据。以下是一个简单的例子，展示了如何在Servlet中获取这些数据并保存到数据库中：




import javax.servlet.*;
import javax.servlet.http.*;
import java.io.*;
import java.sql.*;
 
public class AddProductServlet extends HttpServlet {
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String productName = request.getParameter("productName");
        String productPrice = request.getParameter("productPrice");
        String productDesc = request.getParameter("productDesc");
 
        // 连接数据库等操作...
        Connection conn = null;
        PreparedStatement pstmt = null;
 
        try {
            // 假设你已经建立了数据库连接
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/yourdatabase", "username", "password");
            String sql = "INSERT INTO products (name, price, description) VALUES (?, ?, ?)";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, productName);
            pstmt.setDouble(2, Double.parseDouble(productPrice));
            pstmt.setString(3, productDesc);
            pstmt.executeUpdate();
 
            // 添加成功，重定向到商品列表或其他页面
            response.sendRedirect("productList");
        } catch (SQLException ex) {
            // 处理异常
            ex.printStackTrace();
        } finally {
            // 关闭资源
            if (pstmt != null) pstmt.close();
            if (conn != null) conn.close();
        }
    }
}

在这个Servlet中，我们通过request.getParameter方法获

- 阅读更多 -

postgresql 操作查询jsonb数据

System

2024-09-01

所有,数据库

在PostgreSQL中，可以使用jsonb数据类型来存储JSON数据，并提供了一系列的操作函数来查询这些数据。以下是一些常见的jsonb数据查询示例：

查询JSON对象中的特定字段：




SELECT data->'name' AS name FROM your_table;

查询JSON数组中的元素：




SELECT data->'items'->>0 AS first_item FROM your_table;

查询嵌套JSON对象中的字段：




SELECT data->'info'->>'address' AS address FROM your_table;

查询JSON对象中是否存在某个字段：




SELECT data->>'name' IS NOT NULL FROM your_table;

查询JSON数据中的字段是否等于某个值：




SELECT * FROM your_table WHERE data->>'name' = 'Alice';

在JSON数据中查询多个字段：




SELECT 
  data->>'name' AS name,
  data->'info'->>'address' AS address
FROM your_table;

使用jsonb_set更新JSON数据：




UPDATE your_table 
SET data = jsonb_set(data, '{name}', '"Bob"') 
WHERE id = 1;

使用jsonb_insert更新或者插入JSON数据：




UPDATE your_table 
SET data = jsonb_insert(data, '{address}', '"123 Main St"', true) 
WHERE id = 1;

使用jsonb_agg聚合JSON数组：




SELECT jsonb_agg(data->'name') FROM your_table;

确保在查询或更新jsonb数据时，使用的JSON路径是正确的，并且使用了正确的转义字符。这些操作可以在任何PostgreSQL查询中使用，并且适用于任何包含jsonb类型数据的表。

- 阅读更多 -

Nodejs中mongodb的使用及封装

System

2024-09-01

所有,数据库




const { MongoClient } = require('mongodb');
 
class Database {
  constructor(url) {
    this.connection = null;
    this.url = url;
  }
 
  async connect() {
    if (this.connection) {
      throw new Error('Cannot open a new connection.');
    }
    try {
      this.connection = await MongoClient.connect(this.url, { useNewUrlParser: true, useUnifiedTopology: true });
      console.log('Connected to database.');
    } catch (error) {
      console.error('Error connecting to database:', error);
    }
  }
 
  collection(name) {
    if (!this.connection) {
      throw new Error('No connection established to database.');
    }
    return this.connection.db().collection(name);
  }
 
  close() {
    if (this.connection) {
      this.connection.close();
      this.connection = null;
      console.log('Connection to database closed.');
    }
  }
}
 
module.exports = Database;

这段代码定义了一个名为Database的类，它封装了连接MongoDB数据库的细节。它提供了一个connect方法来建立连接，一个collection方法来获取指定名称的集合，以及一个close方法来关闭连接。使用时，只需创建Database类的实例并调用相应的方法。

System

2024-09-01

所有,java

由于提供完整的系统代码将超出回答字数限制，以下是一个简化的投票管理系统的核心功能示例，包括投票的创建、查看和投票。




// Vote.java (JavaBean)
public class Vote {
    private int id;
    private String title;
    private List<Choice> choices;
    // 省略getter和setter方法
}
 
// Choice.java (JavaBean)
public class Choice {
    private int id;
    private String text;
    private int voteCount;
    // 省略getter和setter方法
}
 
// VoteService.java
public class VoteService {
    public Vote createVote(String title, List<String> choices) {
        // 实现创建投票的逻辑
    }
 
    public Vote getVoteById(int id) {
        // 实现根据ID获取投票的逻辑
    }
 
    public void castVote(int choiceId) {
        // 实现投票逻辑
    }
}
 
// VoteController.java (Servlet)
public class VoteController extends HttpServlet {
    private VoteService voteService = new VoteService();
 
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) {
        String action = req.getParameter("action");
        if ("create".equals(action)) {
            // 显示创建投票页面
        } else if ("view".equals(action)) {
            int voteId = Integer.parseInt(req.getParameter("id"));
            Vote vote = voteService.getVoteById(voteId);
            req.setAttribute("vote", vote);
            // 显示投票页面
        }
    }
 
    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp) {
        String action = req.getParameter("action");
        if ("create".equals(action)) {
            String title = req.getParameter("title");
            String[] choices = req.getParameterValues("choice");
            Vote vote = voteService.createVote(title, Arrays.asList(choices));
            // 重定向到投票详情页面
        } else if ("vote".equals(action)) {
            int choiceId = Integer.parseInt(req.getParameter("choiceId"));
            voteService.castVote(choiceId);
            // 重定向到投票结果页面
        }
    }
}

在这个示例中

- 阅读更多 -

Node.js操作SQLite快速入门

System

2024-09-01

所有,数据库




// 导入SQLite模块
const sqlite3 = require('sqlite3').verbose();
 
// 创建或打开数据库
let db = new sqlite3.Database('./database.sqlite3', (err) => {
  if (err) {
    console.error(err.message);
  } else {
    console.log('Connected to the SQLite database.');
  }
});
 
// 创建表
db.run(`
  CREATE TABLE IF NOT EXISTS messages (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    title TEXT NOT NULL,
    content TEXT,
    created_at DATE DEFAULT (datetime('now', 'localtime'))
  )
`, (err) => {
  if (err) {
    console.error(err.message);
  } else {
    console.log('Messages table created or already exists.');
  }
});
 
// 插入数据
const insertStatement = `
  INSERT INTO messages (title, content)
  VALUES (?, ?)
`;
 
db.run(insertStatement, ['Hello World', 'This is a message.'], (err) => {
  if (err) {
    console.error(err.message);
  } else {
    console.log('A row has been inserted.');
  }
});
 
// 查询数据
db.all('SELECT * FROM messages', (err, rows) => {
  if (err) {
    console.error(err.message);
  } else {
    rows.forEach((row) => {
      console.log(row);
    });
  }
});
 
// 关闭数据库连接
db.close((err) => {
  if (err) {
    console.error(err.message);
  } else {
    console.log('Close the database connection.');
  }
});

这段代码展示了如何在Node.js中使用sqlite3模块来进行基本的数据库操作，包括创建或打开数据库、创建表、插入数据、查询数据以及关闭数据库连接。这是学习如何在Node.js中操作SQLite的一个很好的起点。

System

2024-09-01

所有,redis

在Spring Boot 3.0中，整合Redis使用Jackson2JsonRedisSerializer可能会遇到问题，特别是在配置序列化类时。以下是一个可能的解决方案：




@Configuration
public class RedisConfig {
 
    @Bean
    public RedisCacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
        RedisSerializer<Object> redisSerializer = redisSerializer();
        RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
            .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer));
 
        return RedisCacheManager.builder(redisConnectionFactory)
            .cacheDefaults(cacheConfiguration)
            .build();
    }
 
    @Bean
    public RedisSerializer<Object> redisSerializer() {
        // 使用Jackson2JsonRedisSerializer来进行序列化操作
        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
 
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
 
        jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
 
        return jackson2JsonRedisSerializer;
    }
}

在这个配置类中，我们定义了一个cacheManager方法来创建RedisCacheManager，并且通过redisSerializer方法定义了一个RedisSerializer<Object>的Bean，用于序列化和反序列化Redis中存储的数据。

请注意，在ObjectMapper的配置中，我们使用了enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL)，这样可以在序列化时包含类型信息。这样可以在读取数据时，正确地将对象转换回原来的类型。

如果你在Spring Boot 3.0中遇到了与Jackson2JsonRedisSerializer相关的问题，可能需要检查你的ObjectMapper配置，确保它与你存储在Redis中的数据兼容。如果你使用的是更加严格的类型处理策略，可能需要调整ObjectMapper的配置来适应。

- 阅读更多 -

基于Node.js+Vue3+MongoDB 实现企业门户管理后台

System

2024-09-01

所有,数据库

以下是一个简化的示例，展示如何使用Node.js、Vue 3和MongoDB来创建一个简单的企业门户管理后台。

Node.js (使用Express框架):




const express = require('express');
const mongoose = require('mongoose');
const app = express();
 
// 连接到MongoDB数据库
mongoose.connect('mongodb://localhost:27017/enterprise_portal', { useNewUrlParser: true, useUnifiedTopology: true });
 
// 创建一个Schema
const employeeSchema = new mongoose.Schema({
  name: String,
  email: String,
  department: String
});
 
// 创建Model
const Employee = mongoose.model('Employee', employeeSchema);
 
// 获取所有员工
app.get('/api/employees', async (req, res) => {
  try {
    const employees = await Employee.find();
    res.json(employees);
  } catch (err) {
    res.status(500).json({ message: err.message });
  }
});
 
// 启动服务器
app.listen(3000, () => {
  console.log('Server running on port 3000');
});

Vue 3 (使用Vue CLI创建的项目):




<template>
  <div>
    <h1>员工列表</h1>
    <ul>
      <li v-for="employee in employees" :key="employee._id">
        {{ employee.name }} - {{ employee.email }} - {{ employee.department }}
      </li>
    </ul>
  </div>
</template>
 
<script>
import { ref } from 'vue';
import axios from 'axios';
 
export default {
  setup() {
    const employees = ref([]);
 
    const fetchEmployees = async () => {
      try {
        const response = await axios.get('http://localhost:3000/api/employees');
        employees.value = response.data;
      } catch (error) {
        console.error(error);
      }
    };
 
    fetchEmployees();
 
    return {
      employees,
    };
  },
};
</script>

在这个例子中，我们创建了一个简单的Node.js后端，使用Express框架和Mongoose来与MongoDB通信，并定义了一个API端点来获取员工信息。我们还创建了一个Vue 3前端，使用axios来发送HTTP请求从后端获取数据，并利用Vue的响应式系统来更新DOM。这个例子展示了如何将前后端技术栈结合起来，创建一个功能完整的企业门户管理后台。

- 阅读更多 -