@SpringBootApplication
@EnableEurekaClient
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }

    @Bean
    public RestTemplate restTemplate(RestTemplateBuilder builder) {
        return builder.build();
    }
}

spring.application.name=provider-service
server.port=8080

eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

java -jar eureka-server.jar

mvn spring-boot:run

[databases]
mydb = host=127.0.0.1 port=5432 dbname=mydb

[pgbouncer]
listen_port = 6432
listen_addr = 127.0.0.1
auth_type = md5
auth_file = /etc/pgbouncer/userlist.txt
logfile = /var/log/pgbouncer/pgbouncer.log
pidfile = /var/run/pgbouncer/pgbouncer.pid

[users]
testuser = mypassword

import psycopg2

# PgBouncer connection settings
pgbouncer_conn_string = "dbname=mydb user=testuser host=127.0.0.1 port=6432 password=mypassword"

# Connect to PgBouncer
conn = psycopg2.connect(pgbouncer_conn_string)

# Perform operations using the connection...
cur = conn.cursor()
cur.execute("SELECT version();")
row = cur.fetchone()
print(row)

# Close the connection
cur.close()
conn.close()

# 1. 下载 PostgreSQL 14 安装包
wget https://ftp.postgresql.org/pub/source/v14.0/postgresql-14.tar.gz

# 2. 传输到目标服务器（使用SCP/FTP等）

# 3. 解压安装包
tar -xzf postgresql-14.tar.gz
cd postgresql-14

# 4. 安装依赖（以Debian/Ubuntu为例）
sudo apt-get install build-essential zlibc zlib1g-dev libreadline-dev libpq5 libpq-dev

# 5. 配置环境变量
echo 'export PATH=/path/to/postgresql-14/bin:$PATH' >> ~/.bashrc
source ~/.bashrc

# 6. 创建数据目录
mkdir /path/to/data

# 7. 初始化数据库
./bin/initdb -D /path/to/data

# 8. 启动数据库
./bin/pg_ctl -D /path/to/data -l logfile start

# 9. 创建用户和数据库
./bin/createuser username
./bin/createdb -O username databasename

-- 设置Patch SCN
RMAN> CONFIGURE PATCH CN = 'your_scn_value';

-- 使用Patch SCN进行恢复
RMAN> RESTORE DATABASE;
RMAN> RECOVER DATABASE UNTIL SCN 'your_scn_value';

from masonite.request import Request
from masonite.response import Response

class ThrottleMiddleware:
    def before(self, request: Request, response: Response):
        # 检查是否已经超出了限制次数
        if 'X-Throttle-Limit' in request.headers:
            limit = int(request.headers.get('X-Throttle-Limit'))
            if request.user().throttle_exceeded(limit):
                return response.json({'error': 'Too Many Requests'}, status=429)

    def after(self, request: Request, response: Response):
        # 在这里可以记录请求或更新限制计数器
        pass

from masonite import Session

class User:
    ...

    def throttle_exceeded(self, limit):
        # 获取当前用户的请求计数器
        request_count = Session.get('request_count', 0)

        # 如果请求次数超过限制，返回True
        if request_count >= limit:
            return True

        # 否则更新请求计数并返回False
        Session.set('request_count', request_count + 1)
        return False

from masonite.routes import Get, Post, Route
from app.http.middleware import ThrottleMiddleware

ROUTES = [
    Get('/').middleware(ThrottleMiddleware),
    # 其他路由
]

@Controller
public class FileUploadController {

    private final StorageService storageService;

    @Autowired
    public FileUploadController(StorageService storageService) {
        this.storageService = storageService;
    }

    @GetMapping("/")
    public String index() {
        return "index";
    }

    @PostMapping("/upload")
    public ResponseEntity<String> handleFileUpload(@RequestParam("files") MultipartFile[] files) {
        List<String> fileNames = new ArrayList<>();
        for (MultipartFile file : files) {
            fileNames.add(storageService.store(file));
        }
        return ResponseEntity.ok(fileNames.toString());
    }

    @GetMapping("/download/{filename:.+}")
    public ResponseEntity<Resource> downloadFile(@PathVariable String filename) {
        Resource file = storageService.load(filename);
        return ResponseEntity.ok().header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=\"" + file.getFilename() + "\"")
                .body(file);
    }
}

-- 创建一个新用户（角色）
CREATE USER myuser WITH PASSWORD 'mypassword';

-- 授予对所有表的查询权限（public schema中的所有表）
GRANT SELECT ON ALL TABLES IN SCHEMA public TO myuser;

-- 授予对特定表的查询权限
GRANT SELECT ON mytable TO myuser;

-- 授予对特定函数的执行权限
GRANT EXECUTE ON FUNCTION myfunction TO myuser;

#include <stdio.h>
#include <stdlib.com>
#include <sqlite3.h>

static int callback(void *NotUsed, int argc, char **argv, char **azColName) {
    for(int i = 0; i < argc; i++) {
        printf("%s = %s\n", azColName[i], argv[i] ? argv[i] : "NULL");
    }
    printf("\n");
    return 0;
}

int main() {
    sqlite3 *db;
    char *zErrMsg = 0;
    int rc;
    const char *sql;

    // 打开数据库
    rc = sqlite3_open("example.db", &db);
    if( rc ){
        fprintf(stderr, "无法打开数据库: %s\n", sqlite3_errmsg(db));
        return(0);
    }else{
        fprintf(stdout, "数据库打开成功\n");
    }

    // 创建一个表
    sql = "CREATE TABLE company("  \
          "id INTEGER PRIMARY KEY AUTOINCREMENT," \
          "name TEXT NOT NULL," \
          "age INTEGER," \
          "address TEXT," \
          "salary REAL );";
    rc = sqlite3_exec(db, sql, callback, 0, &zErrMsg);
    if( rc != SQLITE_OK ){
        fprintf(stderr, "SQL错误: %s\n", zErrMsg);
        sqlite3_free(zErrMsg);
    }
    sqlite3_close(db);
    return 0;
}