如果我没有做任何改变，我应该完成交易吗？
await using var transaction = await context.Database.BeginTransactionAsync();
var items = await context.Items.OrderBy(i => i.Id).Take(100).ToListAsync();
if (items.Count == 0)
{
await transaction.CommitAsync();
return false;
}
...
如果我只是保留该方法，会有什么危害吗？或者我应该使用await transaction.CommitAsync();？
任务是在一次交易中接收最多 100 个项目，更改它们，将它们保存到另一个位置，并删除从源收到的项目。
如果有 0 个项目，则不执行任何操作。
我对 SQL Server 执行查询：
cur.execute(f"""
SELECT
*** нужные мне столбцы ***
FROM (
SELECT *
FROM table_1
OFFSET 0 ROWS FETCH NEXT 100 ROWS ONLY
) AS tab_1
JOIN
table_2 tab_2 ON tab_1.id = tab_2.tab_1_id
JOIN
table_3 tab_3 ON tab_2.id = tab_3.tab_2_id
""")
table_data = cur.fetchall()
我假设它将首先从 table_1 中提取第 0 到第 100 行 - 然后根据条件从其余表中选择。执行查询后，我通过将从数据库收到的数据中的唯一值保存到单独的数组中来检查收到了多少数据：
check_route = []
for t in table_data:
if not t[0] in check_route:
check_route.append(t[0])
结果：len（check_route）=> 95...问题是——如果从数据库中选择的条件是 100，为什么是 95？可能是什么原因呢？
对于如此多的代码行，我提前表示歉意！请帮我重组阵列。现在我以这样的对象数组的形式接收数据（有条件地，可能会有更多情况）：
let dataToExpandToCheck= [
{
codePlatform: 'Platform 1',
codeInstance: 'Instance 1',
codeScheme: 'Scheme 1',
codeTable: 'Table 1",
columns: []
},
{
codePlatform: 'Platform 1',
codeInstance: 'Instance 1',
codeScheme: 'Scheme 1',
codeTable: 'Table 2",
columns: []
},
{
codePlatform: 'Platform 1',
codeInstance: 'Instance 1',
codeScheme: 'Scheme 2',
codeTable: 'Table 1",
columns: []
},
{
codePlatform: 'Platform 1',
codeInstance: 'Instance 2',
codeScheme: 'Scheme 1',
codeTable: 'Table 1",
columns: []
},
{
codePlatform: 'Platform 2',
codeInstance: 'Instance 1',
codeScheme: 'Scheme 1',
codeTable: 'Table 1",
columns: []
},
]
问题的本质是，一个平台（codePlatform）内可以有多个实例（codeInstance），一个实例内可以有多个不同的方案（codeScheme），方案内可以有多个不同的表（codeTable）。在我提供的数据中：有2个平台（1和2）。平台 1 内部有 2 个实例（1 和 2），实例 1 内部有模式 1 和模式 2，模式 1 中有 2 个表。在平台 2 上有一个实例、一个模式和一个表。
为了发送数据，我需要重写这个数组，以便 Platform 对象包含其名称和带有其实例的数组，每个实例的对象必须包含实例的名称和包含所有模式的数组，并且每个模式的对象包含其名称和包含表的数组（因此，表对象包括表的名称和其列的数组）。因此，最终数组应该是这样的（我再说一遍，在工作项目中有更多数据和更多选项）：
let restrArray = [
{
codePlatform: 'Platform 1',
instances: [
{
codeInstance: 'Instance 1',
schemes: [
{
codeScheme: 'Scheme1',
tables: [
{
codeTable: 'Table 1',
columns: []
},
{
codeTable: 'Table 2',
columns: []
}
]
},
{
codeScheme: 'Scheme 2',
tables: [
{
codeTable: 'Table 1',
columns: []
}
]
}
]
},
{
codeInstance: 'Instance 2',
schemes: [
{
codeScheme: 'Scheme1',
tables: [
{
codeTable: 'Table 1',
columns: []
}
]
}
]
}
]
},
{
codePlatform: 'Platform 2',
instances: [
{
codeInstance: 'Instance 1',
schemes: [
{
codeScheme: 'Scheme 1',
tables: [
{
codeTable: 'Table 1',
columns: []
}
]
}
]
}
]
}
]
我写下了算法，但它不能正常工作：在某些情况下它不会向平台对象添加实例，有时它会复制数组中的表。请帮助我理解如何重写算法：
const restructureFinalDataToSend = (
dataToExpandToCheck,
setRestructuredDataToSend
) => {
let newDataArray = [];
let instanceArray = [];
let instanceObject = {};
let schemesArray = [];
let schemeObject = {};
let tablesArray = [];
let tableObject = {};
let platformObject = {};
for (let i = 0; i < dataToExpandToCheck.length; i++) {
for (let j = 0; j < i; j++) {
if (
dataToExpandToCheck[j].codePlatform ===
dataToExpandToCheck[i].codePlatform
) {
if (
dataToExpandToCheck[j].codeInstance ===
dataToExpandToCheck[i].codeInstance
) {
if (
dataToExpandToCheck[j].codeScheme ===
dataToExpandToCheck[i].codeScheme
) {
tableObject = {
codeTable: dataToExpandToCheck[i].codeTable,
columns: dataToExpandToCheck[i].columns
};
tablesArray.push(tableObject);
schemeObject = {
codeScheme: dataToExpandToCheck[i].codeScheme,
tables: tablesArray
};
schemesArray.push(schemeObject);
instanceObject = {
codeInstance: dataToExpandToCheck[i].codeInstance,
schemes: schemesArray.reduce((o, i) => {
if (
!o.find((v) => v.codeScheme == i.codeScheme)
) {
o.push(i);
}
return o;
}, [])
};
instanceArray.push(instanceObject);
platformObject = {
codePlatform: dataToExpandToCheck[i].codePlatform,
instances: instanceArray.reduce((o, i) => {
if (
!o.find(
(v) => v.codeInstance == i.codeInstance
)
) {
o.push(i);
}
return o;
}, [])
};
newDataArray.push(platformObject);
} else {
schemeObject = {
codeScheme: dataToExpandToCheck[i].codeScheme,
tables: [
{
codeTable: dataToExpandToCheck[i].codeTable,
columns: dataToExpandToCheck[i].columns
}
]
};
schemesArray.push(schemeObject);
instanceObject = {
codeInstance: dataToExpandToCheck[i].codeInstance,
schemes: schemesArray
};
instanceArray.push(instanceObject);
platformObject = {
codePlatform: dataToExpandToCheck[i].codePlatform,
instances: instanceArray
};
newDataArray.push(platformObject);
}
} else {
instanceObject = {
codeInstance: dataToExpandToCheck[i].codeInstance,
schemes: [
{
codeScheme: dataToExpandToCheck[i].codeScheme,
tables: [
{
codeTable:
dataToExpandToCheck[i].codeTable,
columns: dataToExpandToCheck[i].columns
}
]
}
]
};
instanceArray.push(instanceObject);
platformObject = {
codePlatform: dataToExpandToCheck[i].codePlatform,
instances: instanceArray
};
newDataArray.push(platformObject);
}
} else {
platformObject = {
codePlatform: dataToExpandToCheck[i].codePlatform,
instances: [
{
codeInstance: dataToExpandToCheck[i].codeInstance,
schemes: [
{
codeScheme:
dataToExpandToCheck[i].codeScheme,
tables: [
{
codeTable:
dataToExpandToCheck[i]
.codeTable,
columns:
dataToExpandToCheck[i].columns
}
]
}
]
}
]
};
newDataArray.push(platformObject);
}
}
}
let resultArray = newDataArray.reduce((o, i) => {
if (!o.find((v) => v.codePlatform == i.codePlatform)) {
o.push(i);
}
return o;
}, []);
setRestructuredDataToSend(resultArray);
};
我已经启动了 Vault，它在 10.10.10.10:8200 上运行良好。接下来我想在运行 Gitlab CI 时连接到它。我尝试了说明https://docs.gitlab.com/ci/secrets/hashicorp_vault/，但没有任何作用。有几件事还不完全清楚：
vault auth enable jwt并创建角色vault write auth/jwt/role/runner - <<EOF
{
"role_type": "jwt",
"policies": ["gitlab-runner"],
"token_explicit_max_ttl": 60,
"user_claim": "user_email",
"bound_claims_type": "glob",
"bound_claims": {
"project_id": "66",
"ref_protected": "true"
}
}
EOF
vault write auth/jwt/config \
oidc_discovery_url="https://gitlab.my-gitlab.ru" \
bound_issuer="https://gitlab.my-gitlab.ru"
VAULT_SERVER_URL=http://10.10.10.10:8200到VAULT_AUTH_ROLE=runner我的项目变量中...
manual_authentication:
variables:
VAULT_ADDR: http://10.10.10.10:8200
image: vault:latest
id_tokens:
VAULT_ID_TOKEN:
aud: http://10.10.10.10
script:
- echo $VAULT_ID_TOKEN
- export VAULT_TOKEN="$(vault write -field=token auth/jwt/login role=myproject-example jwt=$VAULT_ID_TOKEN)"
- export PASSWORD="$(vault kv get -field=password secret/myproject)"
但我收到 400 令牌错误：
Error writing data to auth/jwt/login: Error making API request.
URL: PUT http://10.10.10.10:8200/v1/auth/iwt/login
Code: 400. Errors:
* error validating token: invalid issuer (iss) claim
马上就有几个问题：在文档中，在 gitlab-ci.yaml 中aud，指定了 HTTP://vault.example.com，在上面同一文档的示例中，指定了 "bound_audiences": "HTTPS://vault.example.com" - 为什么不同？或者这些是不同的实体？最后我尝试添加角色"bound_audiences": "http://10.10.10.10"，但是也不起作用，就像没有这个参数一样。输出echo $VAULT_ID_TOKEN返回 [MASKED]——无法验证令牌，所以没有办法？请告诉我我做错了什么？以及如何解决Vault与Gitlab之间的通信问题？
我有两个数据库，crm 采用 utf8_general_ci 编码，steriskcdrdb 采用 utf8_general_ci 编码。如何正确撰写请求？更改其中一个数据库中的编码是不可能的，您只需要创建一个请求，这可能吗？
SELECT crm.users.phone_work AS phone,
asteriskcdrdb.cdr.src AS f
FROM asteriskcdrdb.cdr
JOIN crm.users ON crm.users.phone_work = asteriskcdrdb.cdr.src
#1267 - 操作 '=' 的排序规则 (utf8_general_ci,IMPLICIT) 和 (utf8_unicode_ci,IMPLICIT) 混合非法