Tech Blog

Oracle 连接 JOIN、LEFT JOIN、RIGHT JOIN、INNER JOIN、OUTER JOIN

2024-09-04

在Oracle中，JOIN、LEFT JOIN、RIGHT JOIN、INNER JOIN和OUTER JOIN都是用于结合两个或多个表的数据。下面是它们各自的用法和示例：

JOIN: 当你想要结合两个表中有关联的行时，你可以使用JOIN。例如，如果你有一个员工表和一个部门表，并且员工表中的部门ID与部门表中的ID相关联，你可以使用JOIN来只获取那些有关联的行。




SELECT *
FROM Employees E
JOIN Departments D ON E.DepartmentID = D.DepartmentID;

LEFT JOIN: 当你想要获取左表（LEFT JOIN左边的表）的所有记录，即使右表（LEFT JOIN右边的表）中没有匹配的记录时，你可以使用LEFT JOIN。




SELECT *
FROM Employees E
LEFT JOIN Departments D ON E.DepartmentID = D.DepartmentID;

RIGHT JOIN: 当你想要获取右表（RIGHT JOIN右边的表）的所有记录，即使左表（RIGHT JOIN左边的表）中没有匹配的记录时，你可以使用RIGHT JOIN。




SELECT *
FROM Employees E
RIGHT JOIN Departments D ON E.DepartmentID = D.DepartmentID;

INNER JOIN: 当你只想获取两个表中有关联的记录时，你可以使用INNER JOIN。这是JOIN的同义词。




SELECT *
FROM Employees E
INNER JOIN Departments D ON E.DepartmentID = D.DepartmentID;

OUTER JOIN: 当你想要获取两个表中的所有记录，无论它们之间是否有关联时，你可以使用OUTER JOIN。在Oracle中，FULL OUTER JOIN是一个等价的操作。




SELECT *
FROM Employees E
FULL OUTER JOIN Departments D ON E.DepartmentID = D.DepartmentID;

注意：在Oracle中，你不能直接使用LEFT JOIN或RIGHT JOIN的简写形式，你必须明确指定JOIN或者OUTER JOIN。例如，你不能写"SELECT FROM Employees E LEFT D.DepartmentID"，你必须写成"SELECT FROM Employees E LEFT JOIN Departments D ON E.DepartmentID = D.DepartmentID"。

- 阅读更多 -

MongoDB中的TTL索引：自动过期数据的深入解析与使用方式

System

2024-09-04

所有,数据库




// 连接到MongoDB数据库
const MongoClient = require('mongodb').MongoClient;
const url = 'mongodb://localhost:27017';
const dbName = 'exampleDb';
 
MongoClient.connect(url, function(err, client) {
  if(err) throw err;
  console.log("连接成功");
  const db = client.db(dbName);
 
  // 创建一个集合并添加TTL索引
  const collection = db.collection('documents');
  collection.createIndex("expireAt", { expireAfterSeconds: 3600 }, function(err, results) {
    if(err) throw err;
    console.log("TTL索引创建成功");
 
    // 插入一个文档，并设置一个过期时间
    const myDocument = {name: "test", expireAt: new Date()};
    collection.insertOne(myDocument, function(err, result) {
      if(err) throw err;
      console.log("文档插入成功");
 
      // 关闭数据库连接
      client.close();
    });
  });
});

这段代码演示了如何在MongoDB中创建一个TTL索引并插入一个具有过期时间的文档。它首先连接到MongoDB数据库，然后创建一个名为documents的集合并在其expireAt字段上设置一个TTL索引，过期时间设置为3600秒。随后，它插入一个新文档并设置当前时间作为过期时间，然后关闭数据库连接。

- 阅读更多 -

Oracle恢复数据库某张表某一时刻的数据

System

2024-09-04

所有,数据库

为了从Oracle数据库中恢复某张表在某一时刻的数据，你需要使用Oracle的RMAN（Recovery Manager）工具或者从备份的数据库文件中恢复。以下是使用RMAN恢复表的基本步骤：

确定要恢复的时间点。
启动RMAN并连接到目标数据库和/或备份文件。
恢复数据文件（如果数据文件丢失或损坏）。
通过FLASHBACK功能或基于SCN/时间戳的恢复，恢复表。

以下是一个简单的示例，展示如何使用RMAN和FLASHBACK功能恢复丢失的表：




-- 首先，确保数据库处于归档模式，并且有可用的备份。
 
-- 启动RMAN并连接到目标数据库
$ rman target /
 
-- 如果知道丢失表的确切时间，可以尝试以下操作恢复：
RMAN> RUN {
>    SET UNTIL TIME 'YYYY-MM-DD:HH24:MI:SS'; -- 替换为丢失时间的具体值
>    RESTORE TABLESPACE users; -- 假设丢失的表在users表空间中
>    RECOVER TABLESPACE users;
> }
 
-- 如果不知道确切时间，可以使用FLASHBACK功能：
RMAN> FLASHBACK TABLE my_table TO TIME 'YYYY-MM-DD:HH24:MI:SS'; -- 替换为丢失时间的具体值

请注意，这些操作应该在数据库的维护窗口和有充分备份恢复策略的前提下进行。如果表在最近的RMAN备份之后没有变化，那么可以直接从最近的备份中恢复。如果丢失的时间超出了备份的保留期，那么可能需要从备份的归档日志中逐一恢复。

确保在执行恢复操作前备份现有的数据库，并在测试环境中验证恢复过程。如果表结构已经改变或者表名已经不存在，可能需要额外的数据库恢复技巧。

System

2024-09-04

所有,java

Spring Cloud Gateway 是 Spring Cloud 的一个全新项目，该项目提供了一个API网关，它基于Spring 5.0，Spring WebFlux和Project Reactor实现。

Spring Cloud Gateway 的主要目标是为了提供一种简单而有效的方式路由到你的微服务架构。Spring Cloud Gateway 是由Spring Cloud团队提供的一个产品，它使用的是WebFlux中的Reactor模式，以此支持高性能和低延迟。

Spring Cloud Gateway 的核心要点如下：

路由：Spring Cloud Gateway 的基础路由功能，可以通过简单的配置即可实现。




spring:
  cloud:
    gateway:
      routes:
        - id: after_route
          uri: https://example.org
          predicates:
            - Path=/foo/**

断言与过滤器：Spring Cloud Gateway 提供了多种内置的断言和过滤器，同时也支持自定义。




spring:
  cloud:
    gateway:
      routes:
        - id: add_response_header_route
          uri: https://example.org
          predicates:
            - Path=/bar/**
          filters:
            - AddResponseHeader=X-Response-Foo, Bar

负载均衡：Spring Cloud Gateway 支持负载均衡，可以配置不同的负载均衡策略。




spring:
  cloud:
    gateway:
      routes:
        - id: weight_route
          uri: https://example.org
          predicates:
            - Path=/foo/**
          filters:
            - RewritePath=/foo/(?<segment>.*), /$\{segment}
        - id: weight_route
          uri: https://example.org
          predicates:
            - Path=/bar/**
          filters:
            - RewritePath=/bar/(?<segment>.*), /$\{segment}
          metadata:
            weight: 2

服务发现与集成：Spring Cloud Gateway 可以与Spring Cloud服务发现组件（例如Eureka）无缝集成，自动根据服务发现来路由到相应的微服务。




spring:
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true
          lowerCaseServiceId: true

安全性：Spring Cloud Gateway 支持Spring Security，可以很容易地实现对请求的认证和授权。




spring:
  cloud:
    gateway:
      routes:
        - id: secure_route
          uri: https://example.org
          predicates:
            - Path=/secure/**
          filters:
            - name: Security
              args:
                patterns: /secure/**

限流：Spring Cloud Gateway 支持限流功能，可以配置不同的限流策略。




spring:
  cloud:
    gateway:
      routes:
        - id: request_rate_route
          uri: https://example.org
          predicates:
            - Path=/rate/**
          filters:
            - name: RequestRateLimiter
              args:
                redis-rate-limiter.replenishRate: 1
                redis-rate-limiter.burstCapacit

- 阅读更多 -

SpringBoot如何配置动态数据源？原理+实战

System

2024-09-04

所有,java

在Spring Boot中配置动态数据源通常涉及以下步骤：

创建一个动态数据源类，比如DynamicDataSource，继承AbstractRoutingDataSource并实现determineCurrentLookupKey方法。
配置至少两个数据源作为动态数据源的目标。
将动态数据源设置为DataSource的目标。
在服务层或者数据访问层通过某种方式（如上下文持有者）切换数据源。

以下是一个简化的实例代码：




import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
import javax.sql.DataSource;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
 
public class DynamicDataSource extends AbstractRoutingDataSource {
    private final Map<Object, Object> dynamicTargetDataSources = new ConcurrentHashMap<>();
 
    @Override
    protected Object determineCurrentLookupKey() {
        // 从ThreadLocal中获取数据源标识
        return DataSourceContextHolder.getDataSourceType();
    }
 
    public void addDataSource(String key, DataSource dataSource) {
        this.dynamicTargetDataSources.put(key, dataSource);
        this.setTargetDataSources(dynamicTargetDataSources);
        // 在添加数据源后，需要调用afterPropertiesSet()方法来更新内部的数据源映射
        this.afterPropertiesSet();
    }
}
 
// 数据源上下文持有者
public class DataSourceContextHolder {
    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();
 
    public static void setDataSourceType(String dataSourceType) {
        contextHolder.set(dataSourceType);
    }
 
    public static String getDataSourceType() {
        return contextHolder.get();
    }
 
    public static void clearDataSourceType() {
        contextHolder.remove();
    }
}
 
// 配置数据源和DynamicDataSource Bean
@Configuration
public class DataSourceConfig {
 
    @Bean
    public DataSource dataSource() {
        DynamicDataSource dynamicDataSource = new DynamicDataSource();
        // 配置默认数据源
        dynamicDataSource.setDefaultTargetDataSource(primaryDataSource());
        // 初始化时添加其他数据源
        dynamicDataSource.addDataSource("primary", primaryDataSource());
        dynamicDataSource.addDataSource("secondary", secondaryDataSource());
        return dynamicDataSource;
    }
 
    @Bean
    public DataSource primaryDataSource() {
        // 创建并配置主数据源
        return new HikariDataSource();
    }
 
    @Bean
    public DataSource secondaryDataSource() {
        // 创建并配置第二数据源
        return new HikariDataSource();
    }
}
 
// 使用动态数据源
@Service
public class SomeService {
 
    @Autowired
    private JdbcTemplate jdbcTemplate;
 
    public void usePrimaryDataSource() {
        DataSourceContextHolder.setDat

- 阅读更多 -

Redis学习——Redisson 分布式锁集成及其简单使用

System

2024-09-04

所有,redis




import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
 
import java.util.concurrent.TimeUnit;
 
public class RedissonLockExample {
 
    public static void main(String[] args) {
        // 配置RedissonClient
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redisson = Redisson.create(config);
 
        // 获取锁对象实例
        RLock lock = redisson.getLock("myLock");
 
        try {
            // 尝试获取锁，最多等待100秒，锁定之后最多持有锁10秒
            boolean isLocked = lock.tryLock(100, 10, TimeUnit.SECONDS);
            if (isLocked) {
                // 业务逻辑
                System.out.println("Lock acquired");
                // 处理完业务逻辑后，释放锁
            } else {
                // 如果未能获取锁，可以做其他事情
                System.out.println("Lock not acquired");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放锁
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
                System.out.println("Lock released");
            }
        }
 
        // 关闭RedissonClient
        redisson.shutdown();
    }
}

这段代码展示了如何使用Redisson来获取和释放分布式锁。首先，它配置了RedissonClient，连接到本地运行的Redis服务器。然后，它获取一个锁对象，并尝试在100秒内获取锁，锁定时间为10秒。如果成功获取锁，它会执行被锁保护的代码，并在完成后释放锁。最后，它关闭了RedissonClient的连接。这是一个简单的示例，展示了如何在实际应用中使用Redisson进行分布式锁的操作。

- 阅读更多 -

Windows 下postgres 备份、还原

System

2024-09-04

所有,数据库

在Windows环境下，使用PostgreSQL自带的pg\_dump和psql工具进行数据库的备份和恢复的基本步骤如下：

备份

打开命令提示符（CMD）。
使用pg\_dump命令备份数据库。




pg_dump -U 用户名 -h 主机名 -p 端口号 数据库名 > 备份文件路径.sql

例如：




pg_dump -U postgres -h localhost -p 5432 mydatabase > C:\backup\mydatabase.sql

恢复

打开命令提示符（CMD）。
使用psql命令恢复数据库。




psql -U 用户名 -h 主机名 -p 端口号 -d 目标数据库名 < 备份文件路径.sql

例如：




psql -U postgres -h localhost -p 5432 -d mydatabase_restored < C:\backup\mydatabase.sql

确保在执行这些操作时，PostgreSQL服务已经在运行，并且你有足够的权限来访问数据库和执行备份/恢复操作。

- 阅读更多 -

【postgres】pgbackrest 冷备份介绍、命令、脚本

System

2024-09-04

所有,数据库

pgBackRest是一个开源的备份和恢复解决方案，专门为PostgreSQL数据库设计。pgBackRest提供了冷备份、一致性验证和快速的恢复操作。

冷备份介绍

冷备份是在数据库完全关闭的情况下进行的。这意味着在备份开始和结束时，数据库不会接受任何写操作。

使用pgBackRest进行冷备份的命令




# 备份命令
pgbackrest backup --stanza=stanza-name --type=full

--stanza 指定了备份的“stanza”，这是pgBackRest用来组织多个备份集的方式。
--type 指定了备份的类型，full 表示进行全库备份。

备份脚本示例




#!/bin/bash
 
# 设置pgBackRest的配置目录
STANZA=stanza-name
 
# 备份
pgbackrest --stanza=$STANZA backup --type=full
 
# 验证备份
pgbackrest --stanza=$STANZA verify

备份脚本说明

这个脚本首先定义了STANZA变量，指定了备份的stanza名称。接着使用pgbackrest命令执行备份操作，并且添加了--type=full参数指明进行全库备份。最后，执行verify命令验证备份的一致性。

确保在运行脚本之前已经配置好了pgBackRest，并且有正确的权限来执行备份操作。

- 阅读更多 -

本地部署whisper模型（语音转文字）

System

2024-09-04

所有,AIGC

要在本地部署一个Whisper模型（语音转文本），你可以使用开源的语音识别库，如pytorch/whisper。以下是一个简单的例子，展示如何使用whisper库在本地部署一个语音转文本的模型。

首先，确保安装了whisper库：




pip install whisper

然后，你可以使用以下代码示例进行语音转文本的转换：




import whisper
 
# 加载预先训练好的Whisper模型
model_path = 'path_to_your_whisper_model.wav2vec'
model = whisper.load_model(model_path)
 
# 声明音频文件路径
audio_path = 'path_to_your_audio_file.wav'
 
# 执行语音转文本
transcription = model.transcribe(audio_path)
 
# 打印转录结果
print(transcription)

确保替换path_to_your_whisper_model.wav2vec和path_to_your_audio_file.wav为你的模型和音频文件的实际路径。

这个例子假设你已经有了一个训练好的Whisper模型。如果你还没有模型，你可以使用whisper提供的工具来训练你自己的模型，或者使用预训练的模型。

请注意，上述代码只是一个简单的示例，实际使用时可能需要处理音频预处理、解码等细节。

- 阅读更多 -

RMAN恢复某张表的方法

System

2024-09-04

所有,数据库

RMAN (Recovery Manager) 是 Oracle 数据库的备份和恢复工具。要使用 RMAN 恢复某张表，你需要确保你有足够的权限，并且数据库处于归档模式下，以便可以恢复丢失的数据。

以下是使用 RMAN 恢复表的基本步骤：

确认表所在的数据文件。
确定需要恢复到的时间点或 SCN。
使用 RMAN 恢复数据文件。
使用 SQL 检查表是否可用。

以下是一个简单的例子：




-- 假设你需要恢复的表名为 YOUR_SCHEMA.YOUR_TABLE
 
-- 1. 确认表所在的数据文件
SELECT ddf.tablespace_name, ddf.file_name
FROM dba_data_files ddf
JOIN dba_tablespaces dt ON ddf.tablespace_name = dt.tablespace_name
WHERE dt.contents = 'PERMANENT'
AND ddf.owner = 'YOUR_SCHEMA';
 
-- 2. 确定恢复的时间点或 SCN
-- 这通常需要你查看归档日志或者使用其他方法来确定
-- 例如，使用 RMAN 的 "LIST ARCHIVELOG ALL" 命令来查看可用的归档日志
 
-- 使用 RMAN 恢复命令
RMAN> STARTUP FORCE MOUNT; -- 启动实例并挂载数据库
RMAN> RESTORE DATABASE; -- 恢复数据库
RMAN> ALTER DATABASE OPEN RESETLOGS; -- 打开数据库并重置日志
 
-- 3. 恢复表所在的数据文件
RMAN> RESTORE TABLESPACE YOUR_TABLESPACE;
 
-- 4. 恢复表
-- 如果是单表恢复，可以使用如下命令
RMAN> RECOVER TABLE YOUR_SCHEMA.YOUR_TABLE;
 
-- 5. 检查表是否可用
SELECT * FROM YOUR_SCHEMA.YOUR_TABLE;

注意：

实际的恢复步骤可能会根据具体的数据库环境和丢失的数据情况有所不同。
在执行恢复操作前，请确保你有足够的权限，并且已经备份了数据库。
如果表不在上述查询范围内，你可能需要手动指定数据文件或者表空间进行恢复。
如果表在恢复过程中仍然不可用，可能需要进一步的诊断，例如检查归档日志中的错误信息。

- 阅读更多 -