Tech Blog

2024-09-03

在Spring Boot中，可以通过传递命令行参数来动态添加或修改配置文件中的属性。这些参数在应用程序启动时被读取，并可以在Spring的Environment中使用@Value注解或配置属性来获取。

以下是一个如何通过命令行参数动态添加配置的例子：

创建一个Spring Boot项目，并添加一个配置文件application.properties。
在application.properties中添加一个可被覆盖的属性，例如：
```
server.port=8080
```
运行Spring Boot应用程序，并通过命令行添加参数来覆盖该属性，例如：
```
java -jar target/myapp-0.0.1-SNAPSHOT.jar --server.port=8081
```

上述命令会启动Spring Boot应用程序，并将服务端口设置为8081。

如果需要在代码中动态添加配置参数，可以使用Spring Boot的SpringApplicationBuilder：




import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
 
@SpringBootApplication
public class MyApplication {
 
    public static void main(String[] args) {
        SpringApplication app = new SpringApplicationBuilder(MyApplication.class)
                .properties("server.port=8080") // 默认配置
                .build();
        app.run(args); // 运行应用程序，并允许命令行参数覆盖配置
    }
}

在这个例子中，我们在SpringApplicationBuilder中通过.properties()方法添加了一个默认的配置属性。当应用程序运行时，如果命令行参数中指定了相同的属性（例如--server.port=8081），则命令行参数会覆盖默认值。

2024-09-03




@Controller
public class WebSocketController {
 
    @MessageMapping("/chat.sendMessage")
    @SendTo("/topic/public.messages")
    public ChatMessage sendMessage(ChatMessage message) {
        return message;
    }
 
    @MessageMapping("/chat.addUser")
    @SendTo("/topic/public.messages")
    public ChatMessage addUser(@Payload ChatMessage message, 
                               SimpMessageHeaderAccessor headerAccessor) {
        // 设置会话ID
        headerAccessor.getSessionAttributes().put("username", message.getSender());
        return message;
    }
}

这个例子中，我们定义了一个WebSocket控制器，它使用@Controller注解。控制器中有两个处理WebSocket消息的方法，分别处理发送消息和添加用户的动作。方法上的@MessageMapping注解指定了要映射的消息类型的路径，@SendTo注解指定了消息发送的目的地。这样，服务器可以将消息广播到所有订阅的客户端。此外，我们可以通过headerAccessor获取和设置会话属性，例如用户名。

如何使用 Python 从 SQL 数据库生成自动报告

2024-09-03

要使用Python从SQL数据库生成自动报告，你可以使用pandas库来查询数据库，并使用matplotlib或seaborn库来创建图表，最后使用docx或pdfkit库来生成Word或PDF格式的报告。以下是一个简单的例子：




import pandas as pd
from sqlalchemy import create_engine
import matplotlib.pyplot as plt
import seaborn as sns
from docx import Document
import pdfkit
 
# 创建数据库引擎
engine = create_engine('你的数据库连接字符串')
 
# 查询数据
query = "你的SQL查询语句"
df = pd.read_sql_query(query, engine)
 
# 数据分析和可视化
sns.countplot(x='你的分类变量', data=df)
plt.savefig('图表.png')
 
# 创建Word报告
doc = Document()
doc.add_heading('报告标题', 0)
 
# 添加图表
doc.add_picture('图表.png', width=None, height=None)
 
# 添加数据表格
table = doc.add_table(rows=1, cols=len(df.columns))
hdr_cells = table.rows[0].cells
for i, column_name in enumerate(df.columns):
    hdr_cells[i].text = column_name
 
# 将Word报告转换为PDF
pdfkit.from_file('报告.docx', '报告.pdf')

确保你已经安装了所需的库（pandas, sqlalchemy, matplotlib, seaborn, docx, pdfkit），并且替换了连接字符串和查询语句为你自己的数据库信息和分析需求。这个例子提供了一个简单的框架，你可以根据自己的需求进行扩展和定制。

2024-09-03

报错信息不完整，但从给出的部分来看，“pgAdmin无法连接到Docker中的Postgres数据库：连接（conne）”这个错误通常意味着pgAdmin无法建立到PostgreSQL数据库服务器的连接。

解决方法：

确认Postgres服务已在Docker容器中运行。可以使用以下命令检查：
```
docker ps
```
如果Postgres容器正在运行，请检查pgAdmin的连接设置：
- 确保主机名或IP地址正确。如果使用的是Docker容器内部的Postgres，则可能需要使用Docker容器的内部IP或主机名。
- 确认端口号正确。默认情况下，Postgres使用5432端口。
- 确认用户名和密码正确。
检查Postgres容器的网络设置。如果使用了自定义网络，需要确保pgAdmin和Postgres容器在同一网络下。
如果Postgres容器有设置防火墙或其他安全设置，确保pgAdmin的IP地址被允许访问。
如果以上都没问题，尝试重启Postgres容器，并再次从pgAdmin尝试连接。
查看Postgres容器的日志，以获取更多错误信息，这可以通过以下命令完成：
```
docker logs <postgres-container-name>
```
如果问题依然存在，请提供更完整的错误信息以便进一步诊断。

Spring Boot项目打war包并部署TOMCAT

2024-09-03

在Spring Boot项目中打war包并部署到Tomcat需要进行以下步骤：

修改项目的pom.xml文件，将打包方式改为war。
添加Tomcat依赖，因为war包需要在Servlet容器中运行。
排除Spring Boot内置的Tomcat，因为我们已经决定使用外部的Tomcat。
提供一个继承自SpringBootServletInitializer的类，并且覆盖了configure方法。

以下是修改后的pom.xml文件的一个示例：




<project ...>
    ...
    <packaging>war</packaging>
    
    <dependencies>
        ...
        <!-- 排除内置Tomcat -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-tomcat</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <!-- 添加Tomcat依赖 -->
        <dependency>
            <groupId>org.apache.tomcat.embed</groupId>
            <artifactId>tomcat-embed-jasper</artifactId>
            <scope>provided</scope>
        </dependency>
        ...
    </dependencies>
    ...
</project>

接下来，创建一个继承自SpringBootServletInitializer的类：




import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
 
@SpringBootApplication
public class Application extends SpringBootServletInitializer {
 
    @Override
    protected void configure(SpringApplicationBuilder builder) {
        builder.sources(Application.class);
    }
 
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

最后，使用mvn clean package命令打包你的应用程序，得到war文件。然后，将此war文件部署到Tomcat服务器，并启动Tomcat。Spring Boot应用程序将作为一个传统的web应用程序运行在Tomcat容器中。

VBA OR ODBC连接PostgreSQL

2024-09-03

要使用VBA或ODBC连接到PostgreSQL数据库，您需要安装PostgreSQL的ODBC驱动程序，并设置ODBC数据源。以下是使用VBA进行连接的示例代码：




Sub ConnectToPostgreSQL()
    ' 定义变量
    Dim conn As Object
    Dim rs As Object
    Dim query As String
    Dim connectionString As String
    Dim userName As String
    Dim password As String
    
    ' 初始化变量
    Set conn = CreateObject("ADODB.Connection")
    Set rs = CreateObject("ADODB.Recordset")
    query = "SELECT * FROM your_table;" ' 替换为您的查询
    connectionString = "Driver={PostgreSQL ANSI};Server=your_server;Port=your_port;Database=your_database;Uid=your_username;Pwd=your_password;"
    userName = "your_username" ' 替换为您的用户名
    password = "your_password" ' 替换为您的密码
    
    ' 打开连接
    conn.Open connectionString
    
    ' 执行查询并获取结果
    rs.Open query, conn, 3, 3 ' 3, 3 表示adOpenStatic, adLockOptimistic
    
    ' 遍历结果
    While Not rs.EOF
        Debug.Print rs.Fields(0).Value ' 打印第一列的值
        rs.MoveNext
    Wend
    
    ' 关闭记录集和连接
    rs.Close
    conn.Close
    
    ' 清理
    Set rs = Nothing
    Set conn = Nothing
End Sub

请确保将 connectionString 中的 your_server, your_port, your_database, your_username, 和 your_password 替换为您的实际信息。同样，将 query 替换为您要执行的实际SQL查询。

注意：在使用此代码之前，请确保您的计算机上安装了PostgreSQL的ODBC驱动程序，并且已经创建了ODBC数据源。

Elasticsearch 百分位数聚合

2024-09-03

所有,elasticsearch

在Elasticsearch中，可以使用百分位数聚合（Percentile Aggregation）来计算数值字段的特定百分位数值。以下是一个使用Elasticsearch DSL（Elasticsearch DSL，是Elasticsearch的查询语言）定义的百分位数聚合的例子：




GET /_search
{
  "size": 0,
  "aggs": {
    "load_percentiles": {
      "percentiles": {
        "field": "load_time",
        "percents": [
          1,
          5,
          25,
          50,
          75,
          95,
          99
        ]
      }
    }
  }
}

在这个例子中，load_percentiles 是聚合的名称，field 指定了要计算百分位数的字段名称，percents 数组定义了需要计算的百分位数，包括1%, 5%, 25%, 50%, 75%, 95%, 和99%。这个查询将返回每个指定百分位数对应的值。

Django SafeDelete 开源项目指南

2024-09-03




from django.db import models
from safedelete.models import SafeDeleteModel
 
# 定义一个SafeDeleteModel的子类，用于软删除
class MyModel(SafeDeleteModel):
    # 这里定义模型字段
    name = models.CharField(max_length=100)
    # 你可以添加更多的字段...
 
    # 如果你想要自定义软删除的行为，可以覆盖safe_delete方法
    def safe_delete(self, using_db=None, soft=True, *args, **kwargs):
        # 在这里添加你的逻辑
        super().safe_delete(using_db, soft, *args, **kwargs)
 
# 使用MyModel时，它会自动记录软删除的对象，并允许你恢复它们

这段代码演示了如何在Django项目中使用safedelete库来实现模型的软删除功能。通过继承SafeDeleteModel，你可以在不影响数据库完整性的情况下，将模型实例标记为已删除，并且可以随时从软删除状态恢复它们。

2024-09-03

Django Control Center 是一个用于管理 Django 项目的工具，它提供了一个用户友好的界面来管理数据模型、视图、表单和用户权限。

以下是如何使用 Django Control Center 的基本步骤：

安装 Django Control Center：




pip install django-control-center

将 control_center 添加到你的 Django 项目的 INSTALLED_APPS 设置中：




INSTALLED_APPS = [
    # ...
    'control_center',
    # ...
]

运行 Django 的迁移命令来创建必要的数据库表：




python manage.py migrate control_center

确保你的项目有一个管理员账户，并登录到 Django Control Center：




python manage.py createsuperuser

在浏览器中访问 Django Control Center，通常是通过添加 /control-center/ 到你的项目的 URL 之后。
在 Django Control Center 界面中，你可以创建新的数据模型、自定义视图、管理用户权限等。

具体的代码实例将取决于你具体的需求，Django Control Center 提供了一个直观的界面来管理 Django 项目，所以大部分工作是通过点击和配置界面来完成的。

Java进阶-SpringCloud设计模式-工厂模式的设计与详解

2024-09-03

工厂模式在Spring Cloud中的应用常见于创建服务消费者的客户端，例如使用Ribbon或Feign作为负载均衡器。以下是一个简化的例子：




import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
 
// 服务提供者的接口
public interface ServiceProvider {
    @RequestMapping(method = RequestMethod.GET, value = "/service")
    String getService();
}
 
// 工厂方法来创建服务提供者的客户端
public class ServiceProviderFactory {
    public static ServiceProvider getServiceProvider(String serviceUrl) {
        return Feign.builder()
                    .decoder(new JacksonDecoder())
                    .target(ServiceProvider.class, serviceUrl);
    }
}
 
// 使用工厂模式来消费服务
@FeignClient(name = "serviceProviderClient", url = "http://service-provider-url")
public interface ServiceProviderClient extends ServiceProvider {
    // 如果需要特定的Feign客户端定制，可以在这里添加
}
 
// 在应用中使用工厂来创建客户端
ServiceProvider serviceProvider = ServiceProviderFactory.getServiceProviderClient("http://service-provider-url");
String serviceResponse = serviceProvider.getService();

在这个例子中，我们定义了一个服务提供者的接口ServiceProvider，然后通过ServiceProviderFactory工厂类使用Feign创建了一个具体的服务提供者客户端。这样，我们可以在应用中通过工厂方法来获取服务提供者的实例，而不是直接创建。这样的设计模式有助于解耦服务消费者和具体的服务提供者实现，同时也使得单元测试更加简单和直接。