|
|
@ -106,7 +106,7 @@ SELECT $1::TEXT, v, s
|
|
|
|
async.series([
|
|
|
|
async.series([
|
|
|
|
async.apply(helpers.ensureLegacyObjectsType, tx.client, keys, 'zset'),
|
|
|
|
async.apply(helpers.ensureLegacyObjectsType, tx.client, keys, 'zset'),
|
|
|
|
async.apply(query, {
|
|
|
|
async.apply(query, {
|
|
|
|
name: 'sortedSetsAdd',
|
|
|
|
name: isArrayOfScores ? 'sortedSetsAddScores' : 'sortedSetsAdd',
|
|
|
|
text: isArrayOfScores ? `
|
|
|
|
text: isArrayOfScores ? `
|
|
|
|
INSERT INTO "legacy_zset" ("_key", "value", "score")
|
|
|
|
INSERT INTO "legacy_zset" ("_key", "value", "score")
|
|
|
|
SELECT k, $2::TEXT, s
|
|
|
|
SELECT k, $2::TEXT, s
|
|
|
|