分类所有下的文章

2024-09-04

报错："permission denied for schema public" 通常意味着当前数据库用户没有足够的权限来访问或者执行与schema "public" 相关的操作。

解决方法：

确认当前数据库用户：
使用SQL命令 \c 在psql命令行工具中查看当前连接的数据库和用户。
切换用户：
如果需要的话，可以使用 psql -U username -d databasename 命令来切换到有适当权限的用户。
授权：
如果当前用户应该有权限，可以通过以下SQL命令授予权限：
```
GRANT USAGE ON SCHEMA public TO your_user;
```
替换 your_user 为实际的用户名。
角色继承：
确保用户的角色继承设置正确，使其能够从其他角色继承权限。
所有权：
如果schema public的所有者不是当前用户，可以使用以下命令更改所有者：
```
ALTER SCHEMA public OWNER TO your_user;
```
权限传递：
如果你正在使用的是一个应用程序，确保连接数据库的凭据是正确的，并且应用程序具有适当的权限设置。
查看权限：
使用以下命令查看当前用户在public schema上的权限：
```
\dp public
```
文档和支持：
如果上述步骤不能解决问题，查看数据库的官方文档或者寻求数据库管理员的帮助。

请根据实际情况选择适当的解决方法。

2024-09-04

这个错误通常发生在PostgreSQL数据库服务器在没有正常关闭的情况下断电重启时。PostgreSQL在启动时会尝试找到一个有效的检查点记录（checkpoint record），这个记录用于恢复数据库到最后一个已知的一致状态。如果找不到这样的记录，数据库就无法启动，并会报错"could not locate a valid checkpoint record"。

解决方法：

强制恢复：
- 启动PostgreSQL到单用户模式：postgres --single -D /path/to/data/directory
- 运行pg_resetwal来创建新的WAL段并设置一个新的检查点：pg_resetwal -D /path/to/data/directory
- 重启PostgreSQL服务。
备份和恢复：
- 如果有最新的数据库备份，可以从备份中恢复数据库。
修复WAL文件：
- 如果WAL文件没有损坏，可以尝试修复WAL文件，然后重新尝试启动数据库。

在执行以上操作之前，请确保已经备份了数据库，以防数据丢失。如果不熟悉这些操作，建议联系专业的数据库管理员或寻求帮助。

Spring Cloud入门-Ribbon服务消费者(Hoxton版本)

2024-09-04




import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
 
@SpringBootApplication
@EnableDiscoveryClient
public class ConsumerApplication {
 
    @LoadBalanced
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
 
    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }
}

这段代码是一个Spring Cloud服务消费者的入门示例，使用了Ribbon作为负载均衡器。通过@EnableDiscoveryClient注解，该服务消费者将注册为一个需要服务发现的客户端。@LoadBalanced注解表示RestTemplate将使用Ribbon进行负载均衡的HTTP调用。这是一个很基础的入门示例，展示了如何将Ribbon整合到Spring Cloud项目中。

【Spring Cloud一】微服务基本知识

2024-09-04

微服务是一种架构风格，它提倡将单一应用程序划分成一组小的服务，这些服务可以独立部署、独立扩展，服务之间通过明确定义的API进行通信。

以下是Spring Cloud微服务的基本概念：

服务注册与发现：Spring Cloud使用Netflix Eureka实现服务注册与发现。服务提供者启动时会将自己注册到Eureka服务器，消费者会查找服务并消费。
负载均衡：Spring Cloud使用Ribbon实现客户端负载均衡。
断路器：Spring Cloud使用Netflix Hystrix实现断路器模式，防止系统雪崩。
服务网关：Spring Cloud使用Netflix Zuul实现服务网关，负责路由请求至对应服务。
配置管理：Spring Cloud使用Spring Cloud Config实现配置管理。
分布式跟踪：Spring Cloud使用Spring Cloud Sleuth实现日志的分布式跟踪。

示例代码：




@SpringBootApplication
@EnableEurekaClient // 启用Eureka客户端
public class ServiceApplication {
    public static void main(String[] args) {
        SpringApplication.run(ServiceApplication.class, args);
    }
}
 
@RestController
public class ServiceController {
    @Value("${server.port}")
    private String port;
 
    @GetMapping("/service")
    public String service() {
        return "Service running on port: " + port;
    }
}

以上代码展示了一个简单的Spring Boot应用程序，通过@EnableEurekaClient注解将其注册为Eureka客户端，并通过@Value注解注入配置参数。这个服务会将其注册到Eureka服务器，并且可以通过/service路径对外提供服务。

【SQL】DML、DDL、ROLLBACK 、COMMIT详解

2024-09-04

DML（Data Manipulation Language）语句用于操作数据库中的数据，常用的DML语句包括：INSERT、UPDATE、DELETE。

DDL（Data Definition Language）语句用于定义或改变数据库中的对象，如：表、视图等结构，常用的DDL语句包括：CREATE、ALTER、DROP。

ROLLBACK用于撤销到当前事务开始时数据库的状态，它只在一个事务（transaction）中有效。

COMMIT用于保存到当前事务的所有更改，并使其成为数据库中永久的部分。它结束当前事务并开始一个新的事务。

示例代码：




-- 插入数据
INSERT INTO employees (id, name, department) VALUES (1, 'Alice', 'HR');
 
-- 更新数据
UPDATE employees SET name = 'Bob' WHERE id = 1;
 
-- 删除数据
DELETE FROM employees WHERE id = 1;
 
-- 创建表
CREATE TABLE employees (
  id INT PRIMARY KEY,
  name VARCHAR(50),
  department VARCHAR(50)
);
 
-- 修改表结构
ALTER TABLE employees ADD COLUMN email VARCHAR(100);
 
-- 删除表
DROP TABLE employees;
 
-- 开始事务
START TRANSACTION;
 
-- 撤销到事务开始的状态
ROLLBACK;
 
-- 保存更改并结束当前事务
COMMIT;

以上代码展示了如何使用DML、DDL以及ROLLBACK和COMMIT语句进行数据库操作。

POSTGRESQL EDB 企业版 PG 15 独有功能

2024-09-04

在PostgreSQL EDB 企业版中，PG 15 引入了一些独有的功能，包括列存储的并行扫描、更好的自适应查询处理、全新的查询优化器等。以下是一些这些功能的简单示例：

列存储的并行扫描：

在PG 15中，列存储的并行扫描得到了改进，可以显著提高查询性能。




-- 开启并行扫描
SET enable_parallel_scan = on;
 
-- 查询示例
SELECT * FROM table_name;

自适应查询处理：

自适应查询处理是PG 15的另一个独特功能，可以自动调整查询以优化性能。




-- 开启自适应查询处理
SET enable_adaptive_exec = on;
 
-- 查询示例
SELECT * FROM table_name WHERE condition;

全新的查询优化器：

PG 15引入了一个全新的基于规则的优化器，它可以在查询执行计划中生成更多的可能性，从而提高查询性能。




-- 查询示例
SELECT * FROM table_name WHERE condition;

注意：以上代码示例仅为功能使用的简单示例，实际使用时需要根据具体的表结构和查询条件进行调整。

2024-09-04

报红通常是IDE（如IntelliJ IDEA或Eclipse）的代码分析功能提示的，意味着有可能存在一些问题。以下是几种可能的解释和解决方法：

类未找到：确保要自动装配的类在Spring容器中已经被扫描并注册为Bean。
解决方法：确保该类上有@Component、@Service、@Repository或@Controller等注解，并且该类所在的包在主应用类或配置类上的@ComponentScan注解指定的路径中。
存在多个Bean实例：如果有多个符合条件的Bean，Spring无法决定注入哪一个。
解决方法：可以使用@Primary注解在多个Bean中指定一个首选的，或者使用@Qualifier注解指定要注入的具体Bean名称。
Bean还未实例化：如果是一个懒加载的Bean或者其创建过程中有问题。
解决方法：检查该Bean的定义，确保没有循环依赖，并且所有依赖的Bean都能正常创建。
IDE索引问题：有时IDE的索引可能出现问题，导致自动装配失败。
解决方法：尝试重新编译项目，刷新IDE的缓存和索引。
@Autowired不正确使用：可能是使用方式不当，例如在非Bean的普通类中使用。
解决方法：确保@Autowired注解仅用于Spring管理的类中的字段或构造函数上。
依赖项缺失：可能是缺少必要的依赖库。
解决方法：检查pom.xml或build.gradle文件，确保所有必要的依赖都已经正确添加。

如果上述方法都不能解决问题，可能需要检查具体的错误信息，查看Spring的日志输出，或者检查代码其他可能的问题点。

Oracle 各类连接超时相关参数学习

2024-09-04

Oracle数据库中涉及各类连接超时的参数主要有以下几个：

SQLNET.EXPIRE_TIME：这是一个在sqlnet.ora文件中的参数，用于设置服务器端的非活动连接的超时时间。
CONNECT_TIMEOUT：这是一个在sqlnet.ora文件中的参数，用于设置客户端与服务器建立连接的超时时间。
INBOUND_CONNECT_TIMEOUT：这是一个在监听器的配置文件（通常是listener.ora）中的参数，用于设置服务器监听器等待连接初始化的超时时间。
SQLNET.AUTHENTICATION_SERVICES：这是一个在sqlnet.ora文件中的参数，用于设置Oracle的认证方式，如果设置为none，则会导致连接尝试失败，如果设置为all，则会导致连接尝试使用高级认证方式。
GLOBAL_DBNAME：这是一个在tnsnames.ora文件中的参数，用于设置TNS名称的全局数据库名称，对应于数据库的全局名称。
RECV_TIMEOUT：这是一个在sqlnet.ora文件中的参数，用于设置客户端读取服务器响应的超时时间。
SEND_TIMEOUT：这是一个在sqlnet.ora文件中的参数，用于设置客户端发送请求到服务器的超时时间。
CONNECTION_TIMEOUT：这是一个在JDBC连接字符串中的参数，用于设置Java应用程序与Oracle数据库建立连接的超时时间。

以下是设置这些参数的示例：

sqlnet.ora 文件中设置超时参数的例子：




SQLNET.EXPIRE_TIME = 10
CONNECT_TIMEOUT = 10
RECV_TIMEOUT = 10
SEND_TIMEOUT = 10

listener.ora 文件中设置超时参数的例子：




LISTENER =
  (DESCRIPTION_LIST =
    (DESCRIPTION =
      (ADDRESS = (PROTOCOL = TCP)(HOST = localhost)(PORT = 1521))
      (INBOUND_CONNECT_TIMEOUT = 3)
    )
  )

JDBC 连接字符串中设置超时参数的例子：




String url = "jdbc:oracle:thin:@//hostname:port/serviceName?connectionTimeout=10";

请注意，实际设置这些参数时，需要根据实际的Oracle数据库版本和环境来设置，因为不同版本的Oracle数据库支持的参数可能会有所不同。

2024-09-04

以下是一个基于 Ubuntu 20.04 和 Containerd 的 Kubernetes 1.28.1 集群部署的示例步骤：

系统要求：确保系统满足 Kubernetes 和 Docker 的最小要求。

更新系统并安装必要的包：




sudo apt-get update
sudo apt-get install -y apt-transport-https ca-certificates curl
sudo apt-get install -y software-properties-common

添加 Docker 和 Kubernetes 的官方 GPG 密钥：




curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo apt-key add -
sudo apt-key adv --fetch-keys https://apt.kubernetes.io/kubernetes.gpg

添加 Docker 和 Kubernetes 的稳定仓库：




sudo add-apt-repository "deb [arch=amd64] https://download.docker.com/linux/ubuntu $(lsb_release -cs) stable"
sudo add-apt-repository "deb https://apt.kubernetes.io/ kubernetes-xenial main"

再次更新包列表并安装 Docker Engine 和 Kubernetes 相关包：




sudo apt-get update
sudo apt-get install -y docker-ce docker-ce-cli containerd.io
sudo apt-get install -y kubelet kubeadm kubectl

初始化 Kubernetes 集群：




sudo kubeadm init --pod-network-cidr=10.244.0.0/16

设置 kubectl 的配置文件：




mkdir -p $HOME/.kube
sudo cp -i /etc/kubernetes/admin.conf $HOME/.kube/config
sudo chown $(id -u):$(id -g) $HOME/.kube/config

安装 Pod 网络插件（如 Calico）：




kubectl apply -f https://docs.projectcalico.org/manifests/calico.yaml

添加工作节点：
```
kubeadm token create --print-join-command
```
执行上述命令输出的节点加入指令，其他工作节点将通过该指令加入集群。

以上步骤为部署 Kubernetes 1.28.1 集群提供了一个基本的框架。记得根据具体环境调整网络配置和安全设置。

2024-09-04

在Spring Boot中，你可以通过实现Filter接口来创建一个自定义的过滤器，并在过滤器中修改请求体参数。以下是一个简单的例子：

创建一个过滤器类：




import org.springframework.stereotype.Component;
import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.io.BufferedReader;
import java.util.Enumeration;
 
@Component
public class ModifyRequestFilter implements Filter {
 
    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
            throws IOException, ServletException {
        if (request instanceof HttpServletRequest) {
            HttpServletRequest httpServletRequest = (HttpServletRequest) request;
            ModifyableHttpServletRequestWrapper requestWrapper = new ModifyableHttpServletRequestWrapper(
                    httpServletRequest);
            // 在这里修改请求体参数
            requestWrapper.setParameter("paramName", "newValue");
            chain.doFilter(requestWrapper, response);
        }
    }
 
    private static class ModifyableHttpServletRequestWrapper extends HttpServletRequestWrapper {
 
        private final String body;
 
        public ModifyableHttpServletRequestWrapper(HttpServletRequest request) throws IOException {
            super(request);
            StringBuilder stringBuilder = new StringBuilder();
            BufferedReader bufferedReader = request.getReader();
            String line;
            while ((line = bufferedReader.readLine()) != null) {
                stringBuilder.append(line);
            }
            body = stringBuilder.toString();
        }
 
        @Override
        public BufferedReader getReader() {
            return new BufferedReader(new InputStreamReader(getInputStream()));
        }
 
        @Override
        public ServletInputStream getInputStream() {
            final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(body.getBytes());
 
            return new ServletInputStream() {
                @Override
                public boolean isFinished() {
                    r