分类数据库下的文章

PostgreSQL-HA 高可用集群在 Rainbond 上的部署方案

2024-09-04




version: '3'
services:
  proxy:
    image: goodrain/proxy:latest
    environment:
      - PRIVATE_IP=127.0.0.1
      - PUBLIC_IP=127.0.0.1
      - SERVICE_PORT=5234
      - PROXY_MODE=http
    networks:
      - overlay-net
    restart: always
    labels:
      - "rainbond.app-env=enable"
      - "rainbond.proxy=gr-proxy"
 
  node1:
    image: goodrain.me/pgsql-ha:v1.0.0
    environment:
      - PG_MODE=master
      - CLUSTER_NAME=rainbond-pg
      - PG_DATABASE=rainbond
      - PG_USER=rainbond
      - PG_PASSWORD=rainbond
      - PG_ROOT_PASSWORD=rainbond
      - PG_PRIMARY_HOST=node2
      - PG_REPLICATION_USER=replica
      - PG_REPLICATION_PASSWORD=replica
    networks:
      - overlay-net
    restart: always
    labels:
      - "rainbond.app-env=enable"
      - "rainbond.node=gr-node"
      - "rainbond.cluster-init=true"
 
  node2:
    image: goodrain.me/pgsql-ha:v1.0.0
    environment:
      - PG_MODE=replica
      - CLUSTER_NAME=rainbond-pg
      - PG_DATABASE=rainbond
      - PG_USER=rainbond
      - PG_PASSWORD=rainbond
      - PG_ROOT_PASSWORD=rainbond
      - PG_PRIMARY_HOST=node1
      - PG_REPLICATION_USER=replica
      - PG_REPLICATION_PASSWORD=replica
    networks:
      - overlay-net
    restart: always
    labels:
      - "rainbond.app-env=enable"
      - "rainbond.node=gr-node"
 
networks:
  overlay-net:
    driver: overlay

这个YAML文件定义了一个基于Rainbond的PostgreSQL-HA集群的Docker Compose模板。它包括一个代理服务（proxy）和两个数据库节点（node1和node2），这两个节点配置为主从关系，从而形成一个高可用集群。环境变量被用来配置数据库的各种参数，确保集群的正常运行。这个模板展示了如何在Rainbond平台上部署一个高可用的PostgreSQL集群。

Django [实战] 通过表单上传文件

2024-09-04




from django import forms
from django.http import HttpResponseRedirect
from django.shortcuts import render
from .models import Document
 
# 定义上传文件的表单
class DocumentForm(forms.Form):
    file = forms.FileField()
 
# 处理文件上传的视图函数
def upload_file(request):
    if request.method == 'POST':
        form = DocumentForm(request.POST, request.FILES)
        if form.is_valid():
            new_doc = Document(docfile=request.FILES['file'])
            new_doc.save()
            # 重定向到一个新的URL，防止表单的重复提交
            return HttpResponseRedirect('/success/url/')
    else:
        form = DocumentForm()
    return render(request, 'upload.html', {'form': form})

在这个例子中，我们首先定义了一个名为DocumentForm的类来处理文件上传。然后，在upload_file视图函数中，我们检查请求是否是POST方法，如果是，我们实例化表单并将POST数据和文件传递给它。如果表单验证成功，我们将文件保存到数据库，并重定向到一个成功页面。如果请求不是POST或者表单不是有效的，我们渲染带有上传表单的页面供用户填写。

Python 之 Django框架 - 后台管理篇

2024-09-04

在Django框架中，我们可以使用内置的admin应用来管理网站的内容。以下是如何使用Django的admin应用来管理我们的模型的步骤：

创建一个管理员用户：




python manage.py createsuperuser

注册模型到admin：

在你的应用目录中的admin.py文件中，注册你的模型。例如，如果你有一个名为Book的模型，你可以这样注册：




from django.contrib import admin
from .models import Book
 
admin.site.register(Book)

定制admin界面：

你可以通过定义AdminClass来自定义admin界面。例如：




from django.contrib import admin
from .models import Book
 
class BookAdmin(admin.ModelAdmin):
    list_display = ('title', 'author', 'publisher', 'publication_date')
    list_filter = ('publication_date',)
    search_fields = ('title', 'author', 'publisher')
 
admin.site.register(Book, BookAdmin)

使用Django admin：

完成上述步骤后，运行你的Django开发服务器：




python manage.py runserver

然后，在浏览器中访问http://127.0.0.1:8000/admin/，使用之前创建的管理员用户登录，你将能够看到你注册的模型，并可以进行增删改查操作。

以上是使用Django admin的基本步骤，具体的定制化操作可以参考Django的官方文档。

Django 日志配置

2024-09-04

在Django中配置日志，你需要在项目的settings.py文件中设置LOGGIC配置字典。以下是一个基本的日志配置示例：




import os
 
LOGGING = {
    'version': 1,
    'disable_existing_loggers': False,
    'formatters': {
        'standard': {
            'format': '%(asctime)s [%(levelname)s] %(name)s: %(message)s'
        },
    },
    'handlers': {
        'console': {
            'level': 'DEBUG',
            'class': 'logging.StreamHandler',
            'formatter': 'standard'
        },
        'file': {
            'level': 'INFO',
            'class': 'logging.FileHandler',
            'filename': os.path.join(BASE_DIR, 'debug.log'),  # 日志输出文件
            'formatter': 'standard',
            'mode': 'a',  # 追加模式
        },
    },
    'loggers': {
        'django': {
            'handlers': ['console', 'file'],
            'level': 'INFO',
            'propagate': True,
        },
    },
}

在这个配置中，我们定义了两个处理器：console和file。console处理器将日志输出到控制台，而file处理器将日志以追加模式写入到debug.log文件。我们还定义了一个名为django的日志器，它将INFO级别以上的日志信息同时发送到控制台和文件中。

要在Django代码中使用日志，你可以这样做：




import logging
 
logger = logging.getLogger(__name__)
 
def my_view(request):
    logger.debug('A debug message')
    return HttpResponse('Logging example')

这段代码会创建一个名为views的日志器，并记录一条调试信息。记得在项目的__init__.py文件中设置os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_project_name.settings')以确保日志配置正确加载。

连接oracle时出现ORA-12541:TNS:无监听程序的错误

2024-09-04

解释：

ORA-12541错误表示Oracle客户端尝试通过网络连接到Oracle数据库时，无法找到监听器（Listener）。监听器是Oracle Net Services中负责监听和管理客户端连接请求的组件。

解决方法：

确认监听器是否正在运行：
- 在Oracle服务器上，运行lsnrctl status命令查看监听器的状态。
- 如果监听器没有运行，使用lsnrctl start命令启动监听器。
检查监听器配置文件（listener.ora）：
- 确认监听器配置文件中的正确监听端口（默认是1521）和协议设置。
- 确认是否有正确的数据库服务条目，并且服务名或SID与你尝试连接的数据库一致。
确认网络配置文件（tnsnames.ora）：
- 如果使用本地命名方法（TNSNAMES），确认该文件中对应服务名的配置是否正确。
确认防火墙设置：
- 如果服务器上运行着防火墙，确保它没有阻止Oracle监听器端口。
确认服务名是否正确：
- 确保你在连接字符串中使用的服务名（或SID）是正确的，并且数据库实例正在运行。
检查环境变量：
- 确保ORACLE\_HOME和TNS\_ADMIN环境变量指向正确的路径，且监听器配置文件listener.ora和tnsnames.ora存在于这些路径下。
重启监听器服务：
- 在某些情况下，重启监听器服务可能解决问题。
检查Oracle网络配置：
- 使用sqlnet.ora文件中的配置参数进行故障排除。

如果以上步骤无法解决问题，可能需要进一步检查网络配置，查看Oracle的日志文件，或者联系数据库管理员进行进一步的诊断。

2024-09-04

在PostgreSQL中，事务是通过以下SQL命令来管理的：

开启事务：




BEGIN;

提交事务：




COMMIT;

回滚事务：




ROLLBACK;

PostgreSQL默认情况下是自动开启并自动提交事务的。这意味着每个独立的SQL语句都被当作一个事务，如果该语句执行成功，则自动提交；如果执行失败，则自动回滚。

如果你想关闭自动提交，可以通过设置AUTOCOMMIT为OFF来实现。这通常在客户端库或者工具中设置，比如在psql中，你可以使用以下命令：




\set AUTOCOMMIT off

之后，你需要手动使用BEGIN开始一个事务，然后使用COMMIT或ROLLBACK来结束它。

示例：




-- 关闭自动提交
\set AUTOCOMMIT off
 
-- 开启事务
BEGIN;
 
-- 执行一些操作
INSERT INTO my_table(column1) VALUES ('value1');
 
-- 如果一切正常，提交事务
COMMIT;
 
-- 如果操作有错，回滚事务
ROLLBACK;

获取插入postgresql后返回的自增id

2024-09-04

在PostgreSQL中，当你向表中插入一行数据时，如果该表有一个自增的序列（通常是通过SERIAL关键字或者使用IDENTITY如果你使用的是PostgreSQL 10或更高版本），你可以使用RETURNING子句来获取插入操作后生成的自增ID。

下面是一个使用RETURNING子句来获取自增ID的例子：




INSERT INTO your_table (column1, column2, ...)
VALUES (value1, value2, ...)
RETURNING id;

在这个例子中，your_table是你的表名，id是自增列的名字。插入操作后，RETURNING子句会返回新插入行的id列的值。

如果你使用的是PostgreSQL的函数或者存储过程，你可以在函数中使用RETURNING子句，并通过一个输出参数返回这个值。

以下是一个简单的PL/pgSQL函数示例，它插入一行数据到表中并返回自增ID：




CREATE OR REPLACE FUNCTION insert_data_and_get_id(value1 data_type, value2 data_type, ...)
RETURNS integer AS $$
BEGIN
    INSERT INTO your_table (column1, column2, ...)
    VALUES (value1, value2, ...)
    RETURNING id INTO result;
    RETURN result;
END;
$$ LANGUAGE plpgsql;

在这个函数中，value1, value2是你要插入的值，column1, column2是相应的列名。函数使用RETURNING id INTO result来将生成的ID存储在变量result中，然后通过RETURN result返回这个值。

PostgreSQL PgSql序列

2024-09-04

在PostgreSQL中，创建序列（sequence）可以使用CREATE SEQUENCE语句。序列是一个数据库对象，它生成一系列唯一的数值。

以下是创建序列的基本语法：




CREATE SEQUENCE sequence_name
    START WITH initial_value
    INCREMENT BY increment_value
    MINVALUE min_value
    MAXVALUE max_value
    CACHE cache_size
    CYCLE | NO CYCLE;

参数说明：

sequence_name：序列的名称。
initial_value：序列开始的初始值，默认是1。
increment_value：序列每次递增的数值，默认是1。
min_value：序列的最小值，默认是1。
max_value：序列的最大值，默认是2^63-1。
cache_size：缓存多少个序列值，以便更快地访问，默认是1。
CYCLE：当序列达到最大值后，是否循环重新开始，NO CYCLE则不循环。

例如，创建一个简单的序列：




CREATE SEQUENCE my_sequence;

使用序列生成下一个值：




SELECT nextval('my_sequence');

如果需要在表中使用序列生成的值，可以这样使用：




CREATE TABLE my_table (
    id integer PRIMARY KEY DEFAULT nextval('my_sequence'),
    name text NOT NULL
);

这样，每当你向my_table表插入新记录时，id字段会自动使用序列生成的下一个值。

How to terminating Sessions in Oracle

2024-09-04

在Oracle数据库中，可以通过以下方法终止一个会话（session）：

使用ALTER SYSTEM KILL SESSION语句：




ALTER SYSTEM KILL SESSION 'sid,serial#' IMMEDIATE;

其中sid是会话ID，serial#是序列号。

使用ALTER SYSTEM DISCONNECT SESSION语句：




ALTER SYSTEM DISCONNECT SESSION 'sid,serial#' IMMEDIATE;

这将断开会话，但会话在断开后会自动重新连接。

请注意，你需要有足够的权限来执行这些命令，通常需要DBA权限。

例如，如果你要终止会话SID为10，序列号为20的会话，你可以使用：




ALTER SYSTEM KILL SESSION '10,20' IMMEDIATE;

如果你不想立即终止会话，可以省略IMMEDIATE关键字。

在执行这些操作之前，请确保你有正当的理由，因为终止会话可能会导致未保存的工作丢失。