{"id":80,"date":"2025-09-03T20:25:45","date_gmt":"2025-09-03T12:25:45","guid":{"rendered":"http:\/\/caihh.top\/?p=80"},"modified":"2025-09-04T09:35:27","modified_gmt":"2025-09-04T01:35:27","slug":"%e5%9f%ba%e4%ba%8espring-boot%e4%b8%8e%e5%a4%a7%e6%a8%a1%e5%9e%8b%e7%9a%84%e8%87%aa%e7%84%b6%e8%af%ad%e8%a8%80%e6%95%b0%e6%8d%ae%e5%ba%93%e4%ba%a4%e4%ba%92%e5%ae%9e%e8%b7%b5%ef%bc%9a%e6%99%ba%e8%83%bd","status":"publish","type":"post","link":"https:\/\/caihh.top\/index.php\/2025\/09\/03\/%e5%9f%ba%e4%ba%8espring-boot%e4%b8%8e%e5%a4%a7%e6%a8%a1%e5%9e%8b%e7%9a%84%e8%87%aa%e7%84%b6%e8%af%ad%e8%a8%80%e6%95%b0%e6%8d%ae%e5%ba%93%e4%ba%a4%e4%ba%92%e5%ae%9e%e8%b7%b5%ef%bc%9a%e6%99%ba%e8%83%bd\/","title":{"rendered":"\u57fa\u4e8eSpring Boot\u4e0e\u5927\u6a21\u578b\u7684\u81ea\u7136\u8bed\u8a00\u6570\u636e\u5e93\u4ea4\u4e92\u5b9e\u8df5\uff1a\u667a\u80fd\u8bed\u4e49\u5316\u66f4\u65b0\u64cd\u4f5c\u5b9e\u73b0\uff08\u5b66\u4e60\uff09"},"content":{"rendered":"\n

\u672c\u6587\u57fa\u4e8eSpring Boot\u6846\u67b6\uff0c\u7ed3\u5408\u5927\u6a21\u578b\uff08\u672c\u6587\u4f7f\u7528\u4e86\u767e\u5ea6\u6587\u5fc3\u4e00\u8a00\uff09\u7684\u8bed\u4e49\u7406\u89e3\u80fd\u529b\uff0c\u6784\u5efa\u4e86\u4e00\u5957\u81ea\u7136\u8bed\u8a00\u9a71\u52a8\u7684\u6570\u636e\u5e93\u66f4\u65b0\u5b9e\u73b0(\u6570\u636e\u66f4\u65b0\u793a\u4f8b)<\/strong> \u3002<\/p>\n\n\n\n

\u7528\u6237\u53ea\u9700\u8f93\u5165”\u5c06iPhone 13\u4ef7\u683c\u964d\u4e3a4999\u5143”\u7b49\u81ea\u7136\u8bed\u8a00\u6307\u4ee4\uff0c\u5373\u53ef\u81ea\u52a8\u5b8c\u6210\u6570\u636e\u5e93\u8bb0\u5f55\u7684\u7cbe\u51c6\u66f4\u65b0\u3002<\/p>\n\n\n\n

\u6253\u5f00IDEA\u65b0\u5efaSpring Boot\u9879\u76ee<\/p>\n\n\n\n

\"\"<\/div><\/figure>\n\n\n\n

\u6dfb\u52a0\u4f9d\u8d56\u9879\u76ee\uff1aSpring Web\u3001Spring Data JDBC\u3001H2 Database\u3001Lombok\u3002\u6dfb\u52a0\u597d\u4e4b\u540e\u70b9\u51fb\u521b\u5efa\u3002<\/p>\n\n\n\n

\"\"<\/div><\/figure>\n\n\n\n

\u4ee5\u4e0b\u662f\u5728src\/main\/java\/org.example\u7684Java\u6587\u4ef6<\/p>\n\n\n\n

DbApplication.java<\/p>\n\n\n\n

package org.example;\n\nimport org.springframework.boot.SpringApplication;\nimport org.springframework.boot.autoconfigure.SpringBootApplication;\n\n@SpringBootApplication\npublic class DbApplication {\n    public static void main(String[] args) {\n        SpringApplication.run(DbApplication.class, args);\n    }\n}<\/code><\/pre>\n\n\n\n
DbCondition.java<\/p>\n\n\n\n
\npackage org.example;\n\nimport lombok.Data;\n\n@Data\npublic class DbCondition {\n    private String field;\n    private String operator;\n    private Object value;\n}<\/code><\/pre>\n\n\n\n
DbController.java<\/p>\n\n\n\n
package org.example;\n\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.http.ResponseEntity;\nimport org.springframework.web.bind.annotation.*;\n\n@RestController\n@RequestMapping(\"\/api\/db\")\npublic class DbController {\n\n    @Autowired\n    private LLMService LLMService;\n\n    \/\/ \u5904\u7406\u6570\u636e\u66f4\u65b0\u8bf7\u6c42\n    @PostMapping(\"\/update\")\n    public ResponseEntity<UpdateOperationResponse> updateData(@RequestParam String query) {\n        UpdateOperationResponse response = LLMService.processUpdateRequest(query);\n        return ResponseEntity.ok(response);\n    }\n\n}<\/code><\/pre>\n\n\n\n
DbExecutor.java<\/p>\n\n\n\n
package org.example;\n\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.jdbc.core.JdbcTemplate;\nimport org.springframework.stereotype.Service;\n\n@Service\npublic class DbExecutor {\n\n    @Autowired\n    private JdbcTemplate jdbcTemplate;\n\n    \/\/ \u6267\u884cUPDATE SQL\n    public DbOperationResult executeUpdate(String sql) {\n        DbOperationResult result = new DbOperationResult();\n\n        try {\n            \/\/ \u6267\u884c\u66f4\u65b0\n            int affectedRows = jdbcTemplate.update(sql);\n\n            result.setSuccess(true);\n            result.setAffectedRows(affectedRows);\n\n            if (affectedRows == 0) {\n                result.setErrorMessage(\"No rows were updated. The condition may not match any records.\");\n            }\n        } catch (Exception e) {\n            result.setSuccess(false);\n            result.setErrorMessage(e.getMessage());\n        }\n\n        return result;\n    }\n}<\/code><\/pre>\n\n\n\n
DbIntent.java<\/p>\n\n\n\n
package org.example;\n\nimport lombok.Data;\nimport java.util.ArrayList;\nimport java.util.HashMap;\nimport java.util.List;\nimport java.util.Map;\n\n@Data\npublic class DbIntent {\n    private DbOperationType type;\n    private String targetTable;\n    private Map<String, Object> updateValues = new HashMap<>();\n    private List<DbCondition> conditions = new ArrayList<>();\n}<\/code><\/pre>\n\n\n\n
DbOperationResult.java<\/p>\n\n\n\n
package org.example;\n\nimport lombok.Data;\n\n@Data\npublic class DbOperationResult {\n    private boolean success;\n    private Integer affectedRows;\n    private String errorMessage;\n}<\/code><\/pre>\n\n\n\n
DbOperationType.java<\/p>\n\n\n\n
package org.example;\n\npublic enum DbOperationType {\n    SELECT<\/em>,INSERT<\/em>,UPDATE<\/em>,DELETE\n<\/em>}<\/code><\/pre>\n\n\n\n
IntentParser.java<\/p>\n\n\n\n
package org.example;\n\nimport com.fasterxml.jackson.databind.ObjectMapper;\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.stereotype.Service;\n\nimport java.io.IOException;\nimport java.util.List;\n\n@Service\npublic class IntentParser {\n\n   \/* @Autowired\n    private OpenAIService openAIService;*\/\n\n    @Autowired\n    private WenxinClient wenxinClient;\n\n    @Autowired\n    private SchemaManager schemaManager;\n\n    \/\/ \u89e3\u6790\u66f4\u65b0\u64cd\u4f5c\u7684\u81ea\u7136\u8bed\u8a00\u610f\u56fe\n    public DbIntent parseUpdateIntent(String naturalLanguageQuery) {\n        \/\/ \u9996\u5148\u786e\u5b9a\u76ee\u6807\u8868\n        String targetTable = determineTargetTable(naturalLanguageQuery);\n\n        \/\/ \u83b7\u53d6\u8868\u7ed3\u6784\n        SchemaManager.TableSchema tableSchema = schemaManager.getTableSchema(targetTable);\n\n        \/\/ \u6784\u5efa\u63d0\u793a\n        String prompt = buildUpdatePrompt(tableSchema, naturalLanguageQuery);\n\n        \/\/ \u89e3\u6790JSON\u54cd\u5e94\n        String response = null;\n        try {\n            \/\/ \u8c03\u7528\u5927\u6a21\u578b\u89e3\u6790\u610f\u56fe\n            response = wenxinClient.generateCompletion(prompt);\n\n            \/\/ \u63d0\u53d6JSON\u90e8\u5206\n            response = extractJsonFromResponse(response);\n\n            ObjectMapper mapper = new ObjectMapper();\n            return mapper.readValue(response, DbIntent.class);\n        } catch (Exception e) {\n            throw new RuntimeException(\"Failed to parse model response: \" + e.getMessage() + \"\\nResponse: \" + response, e);\n        }\n    }\n\n    \/\/ \u786e\u5b9a\u76ee\u6807\u8868\n    private String determineTargetTable(String query) {\n        List<String> tables = schemaManager.getAllTableNames();\n\n        String tableListStr = String.join<\/em>(\", \", tables);\n        String prompt = \"Based on this user request, determine which database table is being referenced. \" +\n                \"Reply with just the table name, nothing else.\\n\\n\" +\n                \"Available tables: \" + tableListStr + \"\\n\\n\" +\n                \"User request: \" + query;\n\n        String response = null;\n        try {\n            response = wenxinClient.generateCompletion(prompt);\n        } catch (IOException e) {\n            throw new RuntimeException(e);\n        }\n\n        return response.trim().toLowerCase();\n    }\n\n    \/\/ \u6784\u5efa\u66f4\u65b0\u64cd\u4f5c\u7684\u63d0\u793a\n    private String buildUpdatePrompt(SchemaManager.TableSchema schema, String query) {\n        StringBuilder prompt = new StringBuilder();\n\n        \/\/ \u7cfb\u7edf\u6307\u4ee4\n        prompt.append(\"Convert this natural language request into a database update operation.\\n\\n\");\n\n        \/\/ \u8868\u7ed3\u6784\u4fe1\u606f\n        prompt.append(\"Table: \").append(schema.getTableName()).append(\"\\n\");\n        prompt.append(\"Columns: \\n\");\n\n        for (SchemaManager.ColumnSchema column : schema.getColumns()) {\n            prompt.append(\"- \").append(column.getColumnName())\n                    .append(\" (\").append(column.getDataType()).append(\")\");\n\n            if (column.isPrimaryKey()) {\n                prompt.append(\" [PRIMARY KEY]\");\n            }\n            prompt.append(\"\\n\");\n        }\n\n        \/\/ \u7528\u6237\u8bf7\u6c42\n        prompt.append(\"\\nUser request: \").append(query).append(\"\\n\\n\");\n\n\/\/ \u8f93\u51fa\u683c\u5f0f\u8981\u6c42\n        prompt.append(\"Return a JSON object with this exact structure:\\n\");\n        prompt.append(\"{\\n\");\n        prompt.append(\"  \\\"type\\\": \\\"UPDATE\\\",\\n\");\n        prompt.append(\"  \\\"targetTable\\\": \\\"\").append(schema.getTableName()).append(\"\\\",\\n\");\n        prompt.append(\"  \\\"updateValues\\\": {\\n\");\n        prompt.append(\"    \\\"column_name\\\": \\\"new_value\\\"\\n\");\n        prompt.append(\"  },\\n\");\n        prompt.append(\"  \\\"conditions\\\": [\\n\");\n        prompt.append(\"    {\\\"field\\\": \\\"column_name\\\", \\\"operator\\\": \\\"=\\\", \\\"value\\\": \\\"value\\\"}\\n\");\n        prompt.append(\"  ]\\n\");\n        prompt.append(\"}\\n\\n\");\n\n        prompt.append(\"Make sure the field names match exactly with the table schema provided above. \" +\n                \"Convert all values to appropriate data types.\");\n\n        return prompt.toString();\n    }\n\n    \/\/ \u4ece\u54cd\u5e94\u4e2d\u63d0\u53d6JSON\u90e8\u5206\n    private String extractJsonFromResponse(String response) {\n        int startIdx = response.indexOf('{');\n        int endIdx = response.lastIndexOf('}');\n\n        if (startIdx != -1 && endIdx != -1 && endIdx > startIdx) {\n            return response.substring(startIdx, endIdx + 1);\n        }\n\n        return response; \/\/ \u5982\u679c\u627e\u4e0d\u5230JSON\u7ed3\u6784\uff0c\u8fd4\u56de\u539f\u59cb\u54cd\u5e94\n    }\n}<\/code><\/pre>\n\n\n\n
LLMService.java<\/p>\n\n\n\n
package org.example;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;

@Service
@Slf4j
public class LLMService {

    @Autowired
    private IntentParser intentParser;

    @Autowired
    private SqlGenerator sqlGenerator;

    @Autowired
    private DbExecutor dbExecutor;

    \/*@Autowired
    private OpenAIService openAIService;*\/

    @Autowired
    private WenxinClient wenxinClient;

    \/\/ \u5904\u7406\u66f4\u65b0\u6570\u636e\u7684\u81ea\u7136\u8bed\u8a00\u8bf7\u6c42
    public UpdateOperationResponse processUpdateRequest(String naturalLanguageQuery) {
        UpdateOperationResponse response = new UpdateOperationResponse();
        response.setOriginalQuery(naturalLanguageQuery);

        try {
            \/\/ 1. \u89e3\u6790\u610f\u56fe
            DbIntent intent = intentParser.parseUpdateIntent(naturalLanguageQuery);
            response.setIntent(intent);

            \/\/ 2. \u751f\u6210SQL
            String sql = sqlGenerator.generateUpdateSql(intent);
            response.setGeneratedSql(sql);

            \/\/ 3. \u6267\u884cSQL
            DbOperationResult result = dbExecutor.executeUpdate(sql);
            response.setResult(result);

            \/\/ 4. \u751f\u6210\u81ea\u7136\u8bed\u8a00\u89e3\u91ca
            String explanation = generateExplanation(intent, result);
            response.setExplanation(explanation);

        } catch (Exception e) {
            log<\/em>.error(e.getMessage(), e);
            DbOperationResult errorResult = new DbOperationResult();
            errorResult.setSuccess(false);
            errorResult.setErrorMessage(e.getMessage());
            response.setResult(errorResult);
            response.setExplanation(\"\u65e0\u6cd5\u5b8c\u6210\u60a8\u7684\u8bf7\u6c42: \" + e.getMessage());
        }

        return response;
    }

    \/\/ \u751f\u6210\u81ea\u7136\u8bed\u8a00\u89e3\u91ca
    private String generateExplanation(DbIntent intent, DbOperationResult result) {
        if (!result.isSuccess()) {
            return \"\u64cd\u4f5c\u5931\u8d25: \" + result.getErrorMessage();
        }

        \/\/ \u6784\u5efa\u63d0\u793a
        StringBuilder prompt = new StringBuilder();
        prompt.append(\"\u8bf7\u7528\u7b80\u6d01\u7684\u4e2d\u6587\u89e3\u91ca\u4ee5\u4e0b\u6570\u636e\u5e93\u64cd\u4f5c\u7684\u7ed3\u679c\uff1a\\n\\n\");

        \/\/ \u6dfb\u52a0\u610f\u56fe\u548c\u7ed3\u679c\u4fe1\u606f
        prompt.append(\"\u8868: \").append(intent.getTargetTable()).append(\"\\n\");
        prompt.append(\"\u66f4\u65b0\u5185\u5bb9: \").append(intent.getUpdateValues()).append(\"\\n\");
        prompt.append(\"\u6761\u4ef6: \").append(intent.getConditions()).append(\"\\n\");
        prompt.append(\"\u53d7\u5f71\u54cd\u884c\u6570: \").append(result.getAffectedRows()).append(\"\\n\\n\");

        \/\/ \u8c03\u7528LLM\u751f\u6210\u89e3\u91ca
        try {
            return wenxinClient.generateCompletion(prompt.toString());
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }
}<\/code><\/pre>\n\n\n\n
SchemaManager.java<\/p>\n\n\n\n
package org.example;

import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.stream.Collectors;

@Service
public class SchemaManager {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    \/\/ \u83b7\u53d6\u8868\u7ed3\u6784 - \u6700\u7b80\u5316\u7248\u672c
    public TableSchema getTableSchema(String tableName) {
        \/\/ \u9a8c\u8bc1\u8868\u662f\u5426\u5b58\u5728
        List<String> tables = jdbcTemplate.queryForList(
                \"SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = ?\",
                String.class, tableName.toUpperCase()
        );

        if (tables.isEmpty()) {
            throw new RuntimeException(\"Table not found: \" + tableName);
        }

        \/\/ \u83b7\u53d6\u5217\u4fe1\u606f
        List<ColumnSchema> columns = jdbcTemplate.query(
                \"SELECT COLUMN_NAME, DATA_TYPE FROM INFORMATION_SCHEMA.COLUMNS \" +
                        \"WHERE TABLE_NAME = ?\",
                (rs, rowNum) -> {
                    ColumnSchema column = new ColumnSchema();
                    column.setColumnName(rs.getString(\"COLUMN_NAME\").toLowerCase());
                    column.setDataType(rs.getString(\"DATA_TYPE\").toLowerCase());

                    \/\/ \u7b80\u5355\u5047\u8bbe\uff1aid\u5217\u662f\u4e3b\u952e\uff08\u8fd9\u5728\u5927\u591a\u6570\u5e94\u7528\u4e2d\u662f\u5e38\u89c1\u7684\u7ea6\u5b9a\uff09
                    String colName = rs.getString(\"COLUMN_NAME\").toLowerCase();
                    column.setPrimaryKey(colName.equals(\"id\"));

                    return column;
                },
                tableName.toUpperCase()
        );

        TableSchema schema = new TableSchema();
        schema.setTableName(tableName.toLowerCase());
        schema.setColumns(columns);
        return schema;
    }

    \/\/ \u83b7\u53d6\u6240\u6709\u8868\u540d
    public List<String> getAllTableNames() {
        return jdbcTemplate.queryForList(
                \"SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'PUBLIC'\",
                String.class
        ).stream().map(String::toLowerCase).collect(Collectors.toList<\/em>());
    }

    @Data
    public static class TableSchema {
        private String tableName;
        private List<ColumnSchema> columns;

        \/\/ \u68c0\u67e5\u5b57\u6bb5\u662f\u5426\u5b58\u5728
        public boolean hasColumn(String columnName) {
            return columns.stream()
                    .anyMatch(col -> col.getColumnName().equalsIgnoreCase(columnName));
        }

        \/\/ \u83b7\u53d6\u4e3b\u952e\u5217
        public List<String> getPrimaryKeys() {
            return columns.stream()
                    .filter(ColumnSchema::isPrimaryKey)
                    .map(ColumnSchema::getColumnName)
                    .collect(Collectors.toList<\/em>());
        }
    }

    @Data
    public static class ColumnSchema {
        private String columnName;
        private String dataType;
        private boolean primaryKey;
    }
}<\/code><\/pre>\n\n\n\n
SqlGenerator.java<\/p>\n\n\n\n
package org.example;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@Service
public class SqlGenerator {

    @Autowired
    private SchemaManager schemaManager;

    \/\/ \u751f\u6210UPDATE SQL\u8bed\u53e5
    public String generateUpdateSql(DbIntent intent) {
        \/\/ \u9a8c\u8bc1\u610f\u56fe
        validateUpdateIntent(intent);

        StringBuilder sql = new StringBuilder(\"UPDATE \");
        sql.append(intent.getTargetTable()).append(\" SET \");

        \/\/ \u6dfb\u52a0\u8981\u66f4\u65b0\u7684\u5b57\u6bb5\u548c\u503c
        List<String> setStatements = new ArrayList<>();
        for (Map.Entry<String, Object> entry : intent.getUpdateValues().entrySet()) {
            setStatements.add(entry.getKey() + \" = \" + formatValue(entry.getValue()));
        }
        sql.append(String.join<\/em>(\", \", setStatements));

        \/\/ \u6dfb\u52a0WHERE\u6761\u4ef6
        if (intent.getConditions() != null && !intent.getConditions().isEmpty()) {
            sql.append(\" WHERE \");
            List<String> conditionStrings = intent.getConditions().stream()
                    .map(this::formatCondition)
                    .collect(Collectors.toList<\/em>());
            sql.append(String.join<\/em>(\" AND \", conditionStrings));
        } else {
            throw new RuntimeException(\"UPDATE operation must have conditions\");
        }

        return sql.toString();
    }

    \/\/ \u683c\u5f0f\u5316SQL\u503c
    private String formatValue(Object value) {
        if (value == null) {
            return \"NULL\";
        } else if (value instanceof String) {
            return \"'\" + ((String)value).replace(\"'\", \"''\") + \"'\";
        } else if (value instanceof Number) {
            return value.toString();
        } else if (value instanceof Boolean) {
            return ((Boolean)value) ? \"1\" : \"0\";
        } else {
            return \"'\" + value.toString().replace(\"'\", \"''\") + \"'\";
        }
    }

    \/\/ \u683c\u5f0f\u5316\u6761\u4ef6
    private String formatCondition(DbCondition condition) {
        return condition.getField() + \" \" + condition.getOperator() + \" \" +
                formatValue(condition.getValue());
    }

    \/\/ \u9a8c\u8bc1\u66f4\u65b0\u610f\u56fe
    private void validateUpdateIntent(DbIntent intent) {
        if (intent.getType() != DbOperationType.UPDATE<\/em>) {
            throw new RuntimeException(\"Expected UPDATE operation, got: \" + intent.getType());
        }

        if (intent.getUpdateValues() == null || intent.getUpdateValues().isEmpty()) {
            throw new RuntimeException(\"No fields to update\");
        }

        if (intent.getConditions() == null || intent.getConditions().isEmpty()) {
            throw new RuntimeException(\"UPDATE operation must have conditions\");
        }

        \/\/ \u9a8c\u8bc1\u8868\u548c\u5b57\u6bb5\u662f\u5426\u5b58\u5728
        SchemaManager.TableSchema schema = schemaManager.getTableSchema(intent.getTargetTable());

        \/\/ \u9a8c\u8bc1\u66f4\u65b0\u5b57\u6bb5
        for (String field : intent.getUpdateValues().keySet()) {
            if (!schema.hasColumn(field)) {
                throw new RuntimeException(\"Column not found: \" + field);
            }
        }

        \/\/ \u9a8c\u8bc1\u6761\u4ef6\u5b57\u6bb5
        for (DbCondition condition : intent.getConditions()) {
            if (!schema.hasColumn(condition.getField())) {
                throw new RuntimeException(\"Column not found in condition: \" + condition.getField());
            }
        }
    }
}<\/code><\/pre>\n\n\n\n
UpdateOperationResponse.java<\/p>\n\n\n\n
package org.example;

import lombok.Data;

@Data
public class UpdateOperationResponse {
    private String originalQuery;
    private DbIntent intent;
    private String generatedSql;
    private DbOperationResult result;
    private String explanation;
}<\/code><\/pre>\n\n\n\n
WenxinClient.java<\/p>\n\n\n\n
package org.example;\nimport com.fasterxml.jackson.databind.JsonNode;\nimport com.fasterxml.jackson.databind.ObjectMapper;\nimport com.fasterxml.jackson.databind.node.ArrayNode;\nimport com.fasterxml.jackson.databind.node.ObjectNode;\nimport org.apache.http.HttpEntity;\nimport org.apache.http.client.methods.CloseableHttpResponse;\nimport org.apache.http.client.methods.HttpPost;\nimport org.apache.http.entity.StringEntity;\nimport org.apache.http.impl.client.CloseableHttpClient;\nimport org.apache.http.impl.client.HttpClients;\nimport org.apache.http.util.EntityUtils;\nimport org.springframework.beans.factory.annotation.Value;\nimport org.springframework.stereotype.Service;\n\nimport java.io.IOException;\nimport java.nio.charset.StandardCharsets;\nimport java.util.ArrayList;\nimport java.util.List;\n\n@Service\npublic class WenxinClient {\n\n    @Value(\"${wenxin.api.key}\")\n    private String apiKey;\n\n    @Value(\"${wenxin.secret.key}\")\n    private String secretKey;\n\n    private static final String TOKEN_URL <\/em>= \"https:\/\/aip.baidubce.com\/oauth\/2.0\/token\";\n    private static final String API_URL <\/em>= \"https:\/\/api.baiduce.com\/rpc\/2.0\/ai_custom\/v1\/wenxinworkshop\/chat\/completions\";\n    private static final String API_URL_V2 <\/em>= \"https:\/\/qianfan.baidubce.com\/v2\/chat\/completions\";\n    private static final String MODEL <\/em>= \"ernie-bot-4\";\n    private static final String MODEL_new_x1 <\/em>= \"ernie-x1-turbo-32k\";\n    private static final String MODEL_new_4$5 <\/em>= \"ernie-4.5-turbo-128k\";\n\n\n\n    private String accessToken;\n    private long tokenExpireTime;\n\n    \/\/ \u83b7\u53d6\u8bbf\u95ee\u4ee4\u724c\n    private String getAccessToken() throws IOException {\n        \/\/ \u5982\u679c\u4ee4\u724c\u6709\u6548\uff0c\u76f4\u63a5\u8fd4\u56de\n        if (accessToken != null && System.currentTimeMillis<\/em>() < tokenExpireTime) {\n            return accessToken;\n        }\n\n        \/\/ \u5426\u5219\u8bf7\u6c42\u65b0\u4ee4\u724c\n        try (CloseableHttpClient httpClient = HttpClients.createDefault<\/em>()) {\n            HttpPost httpPost = new HttpPost(TOKEN_URL <\/em>+\n                    \"?grant_type=client_credentials&client_id=\" + apiKey +\n                    \"&client_secret=\" + secretKey);\n\n            try (CloseableHttpResponse response = httpClient.execute(httpPost)) {\n                HttpEntity entity = response.getEntity();\n                String result = EntityUtils.toString<\/em>(entity);\n\n                ObjectMapper mapper = new ObjectMapper();\n                JsonNode rootNode = mapper.readTree(result);\n\n                this.accessToken = rootNode.path(\"access_token\").asText();\n                int expiresIn = rootNode.path(\"expires_in\").asInt();\n                this.tokenExpireTime = System.currentTimeMillis<\/em>() + (expiresIn * 1000L);\n\n                return this.accessToken;\n            }\n        }\n    }\n\n    \/\/ \u751f\u6210\u56de\u590d\n    public String generateCompletion(String prompt) throws IOException {\n\/\/        String token = getAccessToken();\n\n        try (CloseableHttpClient httpClient = HttpClients.createDefault<\/em>()) {\n            HttpPost httpPost = new HttpPost(API_URL_V2<\/em>);\n            httpPost.setHeader(\"Content-Type\", \"application\/json\");\n            httpPost.setHeader(\"Authorization\",\"Bearer \"+apiKey);\n\n            ObjectMapper mapper = new ObjectMapper();\n            ObjectNode requestBody = mapper.createObjectNode();\n            requestBody.put(\"model\", MODEL_new_x1<\/em>);\n\n            ArrayNode messages = mapper.createArrayNode();\n            ObjectNode userMessage = mapper.createObjectNode();\n            userMessage.put(\"role\", \"user\");\n            userMessage.put(\"content\", prompt);\n            messages.add(userMessage);\n\n            requestBody.set(\"messages\", messages);\n\n            StringEntity entity = new StringEntity(requestBody.toString(), StandardCharsets.UTF_8<\/em>);\n            httpPost.setEntity(entity);\n\n            try (CloseableHttpResponse response = httpClient.execute(httpPost)) {\n                HttpEntity responseEntity = response.getEntity();\n                String result = EntityUtils.toString<\/em>(responseEntity);\n\n                JsonNode rootNode = mapper.readTree(result);\n                if (rootNode.has(\"error_code\")) {\n                    throw new IOException(\"API error: \" + rootNode.path(\"error_msg\").asText());\n                }\n\n\/\/                return rootNode.path(\"result\").asText();\n                return rootNode.path(\"choices\").path(0).path(\"message\").path(\"content\").asText();\n            }\n        }\n    }\n\n    \/\/ \u53d1\u9001\u5e26\u6709\u7cfb\u7edf\u63d0\u793a\u7684\u5bf9\u8bdd\n    public String generateCompletionWithSystem(String systemPrompt, String userPrompt) throws IOException {\n        String token = getAccessToken();\n\n        try (CloseableHttpClient httpClient = HttpClients.createDefault<\/em>()) {\n            HttpPost httpPost = new HttpPost(API_URL <\/em>+ \"?access_token=\" + token);\n            httpPost.setHeader(\"Content-Type\", \"application\/json\");\n\n            ObjectMapper mapper = new ObjectMapper();\n            ObjectNode requestBody = mapper.createObjectNode();\n            requestBody.put(\"model\", MODEL<\/em>);\n\n            ArrayNode messages = mapper.createArrayNode();\n\n            \/\/ \u6dfb\u52a0\u7cfb\u7edf\u6d88\u606f\n            ObjectNode systemMessage = mapper.createObjectNode();\n            systemMessage.put(\"role\", \"system\");\n            systemMessage.put(\"content\", systemPrompt);\n            messages.add(systemMessage);\n\n            \/\/ \u6dfb\u52a0\u7528\u6237\u6d88\u606f\n            ObjectNode userMessage = mapper.createObjectNode();\n            userMessage.put(\"role\", \"user\");\n            userMessage.put(\"content\", userPrompt);\n            messages.add(userMessage);\n\n            requestBody.set(\"messages\", messages);\n\n            StringEntity entity = new StringEntity(requestBody.toString(), StandardCharsets.UTF_8<\/em>);\n            httpPost.setEntity(entity);\n\n            try (CloseableHttpResponse response = httpClient.execute(httpPost)) {\n                HttpEntity responseEntity = response.getEntity();\n                String result = EntityUtils.toString<\/em>(responseEntity);\n\n                JsonNode rootNode = mapper.readTree(result);\n                if (rootNode.has(\"error_code\")) {\n                    throw new IOException(\"API error: \" + rootNode.path(\"error_msg\").asText());\n                }\n\n                return rootNode.path(\"result\").asText();\n            }\n        }\n    }\n}<\/code><\/pre>\n\n\n\n
\u4ee5\u4e0b\u662fsrc\/main\/resoures\u9700\u8981\u4fee\u6539\u4ee5\u53ca\u6dfb\u52a0\u6587\u4ef6<\/p>\n\n\n\n
application.properties<\/p>\n\n\n\n
spring.application.name=Springboot\nspring.datasource.url=jdbc:h2:mem:testdb\nspring.datasource.driverClassName=org.h2.Driver\nspring.datasource.username=sa\nspring.datasource.password=sa123\nspring.h2.console.enabled=true\nspring.h2.console.path=\/h2-console\n\nopenai.api.key=your_openai_api_key  \/\/\u8fd9\u4e2a\u4e0d\u9700\u8981\u4fee\u6539\nopenai.model=gpt-3.5-turbo\n\n# ???????? - ???????API??\nwenxin.api.key=\u7528\u4f60\u81ea\u5df1\u7684\u6587\u8a00\u4e00\u5fc3api\nwenxin.secret.key=\u7528\u4f60\u81ea\u5df1\u7684\u6587\u8a00\u4e00\u5fc3api   \/\/\u6ca1\u9519\u4e24\u4e2a\u90fd\u662f\u4e00\u6837\u7684\uff0c\u800c\u4e14\u53ea\u9700\u8981\u4fee\u6539\u8fd9\u4e24\u884c\n\nspring.sql.init.mode=always\n<\/em>spring.sql.init.schema-locations=classpath:schema.sql<\/code><\/pre>\n\n\n\n
schema.sql<\/p>\n\n\n\n
DROP TABLE IF EXISTS products;

CREATE TABLE products (
                          id INT AUTO_INCREMENT PRIMARY KEY,
                          product_name VARCHAR(100) NOT NULL,
                          category VARCHAR(50),
                          price DECIMAL(10, 2),
                          stock INT,
                          description TEXT,
                          created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
<\/em>);

INSERT INTO products (product_name, category, price, stock, description) VALUES
                                                                             ('iPhone 13', 'Electronics', 5999.00, 100, 'Apple iPhone 13 smartphone with A15 Bionic chip'),
                                                                             ('Samsung Galaxy S21', 'Electronics', 4599.00, 85, 'Samsung flagship phone with 5G capability'),
                                                                             ('Macbook Pro', 'Computers', 12999.00, 30, 'Apple laptop with M1 Pro chip'),
                                                                             ('Dell XPS 13', 'Computers', 8299.00, 45, 'Dell premium ultrabook with Intel Core i7'),
                                                                             ('Logitech MX Master 3', 'Accessories', 599.00, 200, 'Advanced wireless mouse'),
                                                                             ('Sony WH-1000XM4', 'Audio', 2299.00, 60, 'Wireless noise-cancelling headphones');<\/code><\/pre>\n\n\n\n
pom.xml<\/p>\n\n\n\n
<?xml version=\"1.0\" encoding=\"UTF-8\"?>
<project xmlns=\"http:\/\/maven.apache.org\/POM\/4.0.0\" xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"
         xsi:schemaLocation=\"http:\/\/maven.apache.org\/POM\/4.0.0 https:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd\">
    <modelVersion>4.0.0<\/modelVersion>
    <parent>
        <groupId>org.springframework.boot<\/groupId>
        <artifactId>spring-boot-starter-parent<\/artifactId>
        <version>2.7.18<\/version>
        <relativePath\/>
    <\/parent>
    <groupId>com.example<\/groupId>
    <artifactId>aidb<\/artifactId>
    <version>0.0.1-SNAPSHOT<\/version>
    <description>Spring Boot for database updates<\/description>

    <properties>
        <java.version>11<\/java.version>
    <\/properties>

    <dependencies>
        <!-- Spring Boot \u57fa\u7840\u4f9d\u8d56 -->
        <dependency>
            <groupId>org.springframework.boot<\/groupId>
            <artifactId>spring-boot-starter-web<\/artifactId>
        <\/dependency>
        <dependency>
            <groupId>org.springframework.boot<\/groupId>
            <artifactId>spring-boot-starter-jdbc<\/artifactId>
        <\/dependency>

        <!-- H2\u5185\u5b58\u6570\u636e\u5e93 -->
        <dependency>
            <groupId>com.h2database<\/groupId>
            <artifactId>h2<\/artifactId>
            <scope>runtime<\/scope>
        <\/dependency>

        <!-- HTTP\u5ba2\u6237\u7aef -->
        <dependency>
            <groupId>org.apache.httpcomponents<\/groupId>
            <artifactId>httpclient<\/artifactId>
            <version>4.5.14<\/version>
        <\/dependency>

        <!-- OpenAI\u5ba2\u6237\u7aef -->
        <dependency>
            <groupId>com.theokanning.openai-gpt3-java<\/groupId>
            <artifactId>service<\/artifactId>
            <version>0.12.0<\/version>
        <\/dependency>

        <!-- Lombok -->
        <dependency>
            <groupId>org.projectlombok<\/groupId>
            <artifactId>lombok<\/artifactId>
            <optional>true<\/optional>
        <\/dependency>

        <!-- Jackson -->
        <dependency>
            <groupId>com.fasterxml.jackson.core<\/groupId>
            <artifactId>jackson-databind<\/artifactId>
        <\/dependency>

        <!-- \u6d4b\u8bd5\u4f9d\u8d56 -->
        <dependency>
            <groupId>org.springframework.boot<\/groupId>
            <artifactId>spring-boot-starter-test<\/artifactId>
            <scope>test<\/scope>
        <\/dependency>
        <!-- Spring Core -->
        <dependency>
            <groupId>org.springframework<\/groupId>
            <artifactId>spring-core<\/artifactId>
        <\/dependency>

        <!-- Spring Beans -->
        <dependency>
            <groupId>org.springframework<\/groupId>
            <artifactId>spring-beans<\/artifactId>
        <\/dependency>

        <!-- Spring Context -->
        <dependency>
            <groupId>org.springframework<\/groupId>
            <artifactId>spring-context<\/artifactId>
        <\/dependency>
    <\/dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot<\/groupId>
                <artifactId>spring-boot-maven-plugin<\/artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok<\/groupId>
                            <artifactId>lombok<\/artifactId>
                        <\/exclude>
                    <\/excludes>
                <\/configuration>
            <\/plugin>
        <\/plugins>
    <\/build>
<\/project><\/code><\/pre>\n\n\n\n
\u5199\u5b8cpom.xml\uff0c\u8bf7\u53f3\u51fbpom.xml\uff0c<\/p>\n\n\n\n
\"\"<\/div><\/figure>\n\n\n\n
\u6700\u540e\u8fd0\u884cDbApplication.java\uff0c\u5982\u56fe\uff0c\u5c31\u4ee3\u8868\u4f60\u7684Spring Boot\u5df2\u7ecf\u6253\u5f00\u5566~<\/p>\n\n\n\n
\"\"<\/div><\/figure>\n\n\n\n
\u6d4b\u8bd5\u529f\u80fd\uff1a<\/p>\n\n\n\n
\u5e94\u7528\u542f\u52a8\u540e\uff0c\u53ef\u4ee5\u901a\u8fc7\u4ee5\u4e0b\u65b9\u5f0f\u6d4b\u8bd5<\/p>\n\n\n\n
curl -X POST \"http:\/\/localhost:8080\/api\/db\/update?query=\u5c06iPhone 13\u7684\u4ef7\u683c\u6539\u4e3a4999\u5143\"<\/code><\/pre>\n\n\n\n
\u6211\u662f\u8bf7\u6559\u9999\u9999\u540c\u5b66\u5b66\u4e60\u4f7f\u7528apifox\uff0c\u6ca1\u4e0b\u8f7d\u9700\u8981\u53bb\u5b98\u7f51\u4e0b\u8f7d\u54df~\u4e0b\u9762\u662f\u4f7f\u7528apifox\u7684\u8fc7\u7a0b<\/p>\n\n\n\n
\"\"<\/div><\/figure>\n\n\n\n
\u70b9\u51fb\u53d1\u9001\u4e4b\u540e\u9700\u8981\u7b49\u4e00\u7b49…<\/p>\n\n\n\n
\"\"<\/div><\/figure>\n\n\n\n
\u201c\u8be5\u64cd\u4f5c\u6210\u529f\u4fee\u6539\u4e861\u6761\u7b26\u5408\u6761\u4ef6\u7684\u8bb0\u5f55\u201d\uff0c\u606d\u559c\u4f60\uff0c\u6210\u529f\u5566\uff01<\/p>\n\n\n\n
\"\"<\/div><\/figure>\n\n\n\n
\u8bbf\u95eeH2\u63a7\u5236\u53f0\u67e5\u770b\u6570\u636e\u53d8\u5316<\/p>\n\n\n\n
1.\u6253\u5f00\u6d4f\u89c8\u5668\u8bbf\u95ee\uff1ahttp:\/\/localhost:8080\/h2-console<\/a><\/p>\n\n\n\n
2.\u4f7f\u7528\u4ee5\u4e0b\u914d\u7f6e\u94fe\u63a5\uff1a<\/p>\n\n\n\n