feat(sqlCompletion): support insert all-column completion

This commit is contained in:
wuxiemian authored and GitHub committed 2026-07-06 01:29:23 +08:00
1 parent 4afc3297e1
commit 3fdcc2d454
4 files changed
+152 -15

No files matched your search

@@ -88,4 +88,13 @@ describe("semantic SQL completion candidates", () => {
expect(items.find((item) => item.label === "User Name")?.apply).toBe('"User Name"'); expect(items.find((item) => item.label === "User Name")?.apply).toBe('"User Name"');
}); });
it("suggests all target columns for insert column lists", () => {
const columnsByTable = new Map<string, SqlCompletionColumn[]>([["users", ["id", "name", "email"].map((name) => ({ name, table: "users" }))]]);
const { context, items } = semanticCompletion("INSERT INTO users (|", { columnsByTable });
expect(context.insertTable).toBe("users");
expect(items.find((item) => item.type === "snippet" && item.label === "users.*")?.apply).toBe("id, name, email");
});
}); });
@@ -160,7 +160,7 @@ describe("sqlCompletion scoped context classification", () => {
expect(context.contextKind).toBe("column"); expect(context.contextKind).toBe("column");
expect(context.insertSchema).toBe("dbo"); expect(context.insertSchema).toBe("dbo");
expect(context.insertTable).toBe("users"); expect(context.insertTable).toBe("Users");
expect(context.exclusiveColumnSuggestions).toBe(true); expect(context.exclusiveColumnSuggestions).toBe(true);
}); });
+49 -14
View File
@@ -1256,6 +1256,7 @@ class SqlCompletionProvider {
if (!context.exclusiveTableSuggestions && context.suggestColumns) { if (!context.exclusiveTableSuggestions && context.suggestColumns) {
this.items.push(...buildColumnItems(context, this.input.columnsByTable, this.dialect)); this.items.push(...buildColumnItems(context, this.input.columnsByTable, this.dialect));
this.items.push(...buildSelectAllColumnItems(context, this.input.columnsByTable, this.t, this.dialect)); this.items.push(...buildSelectAllColumnItems(context, this.input.columnsByTable, this.t, this.dialect));
this.items.push(...buildInsertAllColumnItems(context, this.input.columnsByTable, this.t, this.dialect));
} }
if (context.referencedTables.length > 0 && !context.suggestColumns && !context.insertTable) { if (context.referencedTables.length > 0 && !context.suggestColumns && !context.insertTable) {
@@ -1957,11 +1958,12 @@ function detectComparisonLeftColumn(beforeCursor: string): string | undefined {
} }
function detectInsertColumnListContext(beforeCursor: string): { table: string; schema?: string } | null { function detectInsertColumnListContext(beforeCursor: string): { table: string; schema?: string } | null {
const cleaned = beforeCursor // Keep quoted identifiers intact so schema/table targets resolve to their
.replace(/'[^']*'/g, "''") // real names instead of placeholder string contents.
.replace(/"[^"]*"/g, '""') const cleaned = beforeCursor.replace(/'[^']*'/g, "''");
.toLowerCase(); const identifier = '(?:"[^"]+"|`[^`]+`|[A-Za-z_][\\w$]*)';
const match = /\binsert\s+into\s+([A-Za-z_][\w$]*(?:\.[A-Za-z_][\w$]*)?)\s*\([^)]*$/i.exec(cleaned); const qualifiedIdentifier = `${identifier}(?:\\.${identifier})?`;
const match = new RegExp(`\\binsert\\s+into\\s+(${qualifiedIdentifier})\\s*\\([^)]*$`, "i").exec(cleaned);
if (!match) return null; if (!match) return null;
const fullTable = match[1]; const fullTable = match[1];
if (!fullTable) return null; if (!fullTable) return null;
@@ -2744,6 +2746,27 @@ function buildSelectAllColumnItems(context: SqlCompletionContext, columnsByTable
return items; return items;
} }
function buildInsertAllColumnItems(context: SqlCompletionContext, columnsByTable: Map<string, SqlCompletionColumn[]>, t?: SqlCompletionTranslations, dialect?: "mysql" | "postgres" | "sqlserver"): SqlCompletionItem[] {
if (!context.insertTable) return [];
const columns = uniqueColumnsByName(columnsForInsertTarget(context, columnsByTable));
if (columns.length === 0) return [];
const label = `${context.insertTable}.*`;
if (!selectAllColumnItemMatchesPrefix(label, { name: context.insertTable, schema: context.insertSchema }, columns, context.prefix)) return [];
const expansion = columns.map((column) => quoteSqlIdentifier(column.name, dialect)).join(", ");
const countText = (t?.starExpansionColumns ?? "{count} columns").replace("{count}", String(columns.length));
return [
{
label,
type: "snippet" as const,
detail: `${countText}: ${expansion.length > 60 ? expansion.slice(0, 57) + "..." : expansion}`,
apply: expansion,
boost: 2450 + selectAllColumnItemPrefixBoost(label, { name: context.insertTable, schema: context.insertSchema }, columns, context.prefix),
},
];
}
function referencedTablesForSelectAllColumns(context: SqlCompletionContext): SqlCompletionReferencedTable[] { function referencedTablesForSelectAllColumns(context: SqlCompletionContext): SqlCompletionReferencedTable[] {
if (!context.qualifier) return context.referencedTables; if (!context.qualifier) return context.referencedTables;
const qualifier = context.qualifier; const qualifier = context.qualifier;
@@ -2986,25 +3009,37 @@ function isInTableListContext(beforeToken: string): boolean {
return /,\s*$/.test(beforeToken) && /\b(?:from|join|update|into)\b/i.test(beforeToken); return /,\s*$/.test(beforeToken) && /\b(?:from|join|update|into)\b/i.test(beforeToken);
} }
function buildColumnItems(context: SqlCompletionContext, columnsByTable: Map<string, SqlCompletionColumn[]>, dialect?: "mysql" | "postgres" | "sqlserver"): SqlCompletionItem[] { function collectCompletionColumns(columnsByTable: Map<string, SqlCompletionColumn[]>): Array<SqlCompletionColumn & { key: string }> {
// Collect all columns from the map (all tables have been fetched)
const allColumns: Array<SqlCompletionColumn & { key: string }> = []; const allColumns: Array<SqlCompletionColumn & { key: string }> = [];
for (const [key, cols] of columnsByTable.entries()) { for (const [key, cols] of columnsByTable.entries()) {
for (const col of cols) { for (const col of cols) {
allColumns.push({ ...col, key }); allColumns.push({ ...col, key });
} }
} }
return allColumns;
}
function columnsForInsertTarget(context: SqlCompletionContext, columnsByTable: Map<string, SqlCompletionColumn[]>): Array<SqlCompletionColumn & { key: string }> {
if (!context.insertTable) return [];
const tableKey = normalizeIdentifierPart(context.insertTable);
const schemaKey = context.insertSchema ? normalizeIdentifierPart(context.insertSchema) : undefined;
const qualifiedKey = schemaKey ? normalizeCompletionKey(`${context.insertSchema}.${context.insertTable}`) : undefined;
return collectCompletionColumns(columnsByTable).filter((column) => {
if (normalizeIdentifierPart(column.table) !== tableKey) return false;
if (!schemaKey) return true;
if (column.schema && normalizeIdentifierPart(column.schema) === schemaKey) return true;
return !!qualifiedKey && normalizeCompletionKey(column.key) === qualifiedKey;
});
}
function buildColumnItems(context: SqlCompletionContext, columnsByTable: Map<string, SqlCompletionColumn[]>, dialect?: "mysql" | "postgres" | "sqlserver"): SqlCompletionItem[] {
// Collect all columns from the map (all tables have been fetched)
const allColumns = collectCompletionColumns(columnsByTable);
// Handle INSERT column list: filter to only the target table // Handle INSERT column list: filter to only the target table
let relevantCols = allColumns; let relevantCols = allColumns;
if (context.insertTable) { if (context.insertTable) {
const tableLower = context.insertTable.toLowerCase(); relevantCols = columnsForInsertTarget(context, columnsByTable);
if (context.insertSchema) {
const schemaLower = context.insertSchema.toLowerCase();
relevantCols = allColumns.filter((c) => c.table.toLowerCase() === tableLower && (c.schema?.toLowerCase() === schemaLower || c.key.toLowerCase() === `${schemaLower}.${tableLower}`));
} else {
relevantCols = allColumns.filter((c) => c.table.toLowerCase() === tableLower);
}
} else if (context.qualifier) { } else if (context.qualifier) {
const q = context.qualifier; const q = context.qualifier;
const qLower = q.toLowerCase(); const qLower = q.toLowerCase();
+93
View File
@@ -1297,6 +1297,13 @@ test("detects INSERT INTO with schema-qualified table", () => {
assert.equal(context.insertSchema, "public"); assert.equal(context.insertSchema, "public");
}); });
test("detects MySQL backtick-qualified INSERT INTO column list context", () => {
const sql = "INSERT INTO `other_db`.`orders` (";
const context = getSqlCompletionContext(sql, sql.length);
assert.equal(context.insertTable, "orders");
assert.equal(context.insertSchema, "other_db");
});
test("suggests columns for INSERT INTO target table", () => { test("suggests columns for INSERT INTO target table", () => {
const items = buildSqlCompletionItems("INSERT INTO users (", "INSERT INTO users (".length, { const items = buildSqlCompletionItems("INSERT INTO users (", "INSERT INTO users (".length, {
tables, tables,
@@ -1309,6 +1316,92 @@ test("suggests columns for INSERT INTO target table", () => {
assert.ok(columnItems.some((item) => item.label === "email")); assert.ok(columnItems.some((item) => item.label === "email"));
}); });
test("suggests all target columns for INSERT INTO column list", () => {
const items = buildSqlCompletionItems("INSERT INTO users (", "INSERT INTO users (".length, {
tables,
columnsByTable,
});
const allColumns = items.find((item) => item.type === "snippet" && item.label === "users.*");
assert.ok(allColumns);
assert.equal(allColumns.apply, "id, name, email");
});
test("keeps INSERT INTO all-column expansion available after a column prefix", () => {
const items = buildSqlCompletionItems("INSERT INTO users (id", "INSERT INTO users (id".length, {
tables,
columnsByTable,
});
const allColumns = items.find((item) => item.type === "snippet" && item.label === "users.*");
assert.ok(allColumns);
assert.equal(allColumns.apply, "id, name, email");
});
test("quotes PostgreSQL identifiers in INSERT INTO all-column expansion", () => {
const sql = 'INSERT INTO public."OrderLines" (';
const items = buildSqlCompletionItems(sql, sql.length, {
tables: postgresQuotedTables,
columnsByTable: postgresQuotedColumnsByTable,
databaseType: "postgres",
dialect: "postgres",
});
const allColumns = items.find((item) => item.type === "snippet" && item.label === "OrderLines.*");
assert.ok(allColumns);
assert.equal(allColumns.apply, 'article, "OrderId", "User", "has""quote"');
});
test("suggests all target columns for schema-qualified INSERT INTO column lists", () => {
const sql = "INSERT INTO dbo.Users (";
const items = buildSqlCompletionItems(sql, sql.length, {
tables: [{ name: "Users", schema: "dbo", type: "table" }],
columnsByTable: new Map([
[
"dbo.Users",
[
{ name: "Id", table: "Users", schema: "dbo", dataType: "bigint" },
{ name: "DisplayName", table: "Users", schema: "dbo", dataType: "nvarchar" },
],
],
]),
databaseType: "sqlserver",
dialect: "sqlserver",
});
const allColumns = items.find((item) => item.type === "snippet" && item.label === "Users.*");
assert.ok(allColumns);
assert.equal(allColumns.apply, "Id, DisplayName");
});
test("scopes INSERT INTO all-column expansion to the database-qualified MySQL target", () => {
const sql = "INSERT INTO other_db.orders (";
const items = buildSqlCompletionItems(sql, sql.length, {
tables: [{ name: "orders", schema: "other_db", type: "table" }],
columnsByTable: mysqlCrossDatabaseColumnsByTable,
databaseType: "mysql",
dialect: "mysql",
});
const allColumns = items.find((item) => item.type === "snippet" && item.label === "orders.*");
assert.ok(allColumns);
assert.equal(allColumns.apply, "id, number, status");
});
test("suggests all target columns for MySQL backtick-qualified INSERT INTO", () => {
const sql = "INSERT INTO `other_db`.`orders` (";
const items = buildSqlCompletionItems(sql, sql.length, {
tables: [{ name: "orders", schema: "other_db", type: "table" }],
columnsByTable: mysqlCrossDatabaseColumnsByTable,
databaseType: "mysql",
dialect: "mysql",
});
const allColumns = items.find((item) => item.type === "snippet" && item.label === "orders.*");
assert.ok(allColumns);
assert.equal(allColumns.apply, "id, number, status");
});
// --- Column data type in detail --- // --- Column data type in detail ---
test("shows column data type in detail", () => { test("shows column data type in detail", () => {