nocodb · DarkPhoenix2704 · Jun 20, 2025 · Jun 19, 2025 · Jun 19, 2025 · Jun 19, 2025
diff --git a/packages/nocodb/src/constants/index.ts b/packages/nocodb/src/constants/index.ts
@@ -22,8 +22,14 @@ export const NC_EMAIL_ASSETS_BASE_URL = 'https://cdn.nocodb.com/emails/v2';
 
 export const NC_RECURSIVE_MAX_DEPTH = 7;
 
+export const QUERY_STRING_FIELD_ID_ON_RESULT = 'fieldIdOnResult';
+
 export const S3_PATCH_KEYS = [
   'uploads',
   'thumbnails',
   ...(Object.values(PublicAttachmentScope) as string[]),
 ];
+
+export const V3_INSERT_LIMIT = 10;
+export const MAX_NESTING_DEPTH = 3;
+export const MAX_CONCURRENT_TRANSFORMS = 50;
diff --git a/packages/nocodb/src/db/BaseModelSqlv2.ts b/packages/nocodb/src/db/BaseModelSqlv2.ts
@@ -122,6 +122,7 @@ import {
 } from '~/utils';
 import { MetaTable } from '~/utils/globals';
 import { chunkArray } from '~/utils/tsUtils';
+import { QUERY_STRING_FIELD_ID_ON_RESULT } from '~/constants';
 
 dayjs.extend(utc);
 
@@ -211,6 +212,9 @@ class BaseModelSqlv2 implements IBaseModelSqlV2 {
       extractOnlyPrimaries,
       extractOrderColumn,
       apiVersion,
+      skipSubstitutingColumnIds:
+        this.context.api_version === NcApiVersion.V3 &&
+        query?.[QUERY_STRING_FIELD_ID_ON_RESULT] === 'true',
     });
 
     await this.selectObject({
@@ -226,6 +230,9 @@ class BaseModelSqlv2 implements IBaseModelSqlV2 {
       data = await this.execAndParse(qb, null, {
         first: true,
         apiVersion,
+        skipSubstitutingColumnIds:
+          this.context.api_version === NcApiVersion.V3 &&
+          query?.[QUERY_STRING_FIELD_ID_ON_RESULT] === 'true',
       });
     } catch (e) {
       if (
@@ -408,6 +415,7 @@ class BaseModelSqlv2 implements IBaseModelSqlV2 {
       validateFormula?: boolean;
       throwErrorIfInvalidParams?: boolean;
       limitOverride?: number;
+      skipSubstitutingColumnIds?: boolean;
     } = {},
   ): Promise<any> {
     const {
@@ -565,7 +573,8 @@ class BaseModelSqlv2 implements IBaseModelSqlV2 {
     let data;
     try {
       data = await this.execAndParse(qb, undefined, {
-        apiVersion: args.apiVersion,
+        apiVersion: args.apiVersion ?? this.context.api_version,
+        skipSubstitutingColumnIds: options.skipSubstitutingColumnIds,
       });
     } catch (e) {
       if (validateFormula || !haveFormulaColumn(columns)) throw e;
@@ -2645,7 +2654,11 @@ class BaseModelSqlv2 implements IBaseModelSqlV2 {
     }
   }
 
-  async chunkList(args: { pks: string[]; chunkSize?: number }) {
+  async chunkList(args: {
+    pks: string[];
+    chunkSize?: number;
+    apiVersion?: NcApiVersion;
+  }) {
     const { pks, chunkSize = 1000 } = args;
 
     const data = [];
@@ -2656,6 +2669,7 @@ class BaseModelSqlv2 implements IBaseModelSqlV2 {
       const chunkData = await this.list(
         {
           pks: chunk.join(','),
+          apiVersion: args.apiVersion,
         },
         {
           limitOverride: chunk.length,

diff --git a/packages/nocodb/src/helpers/dbHelpers.ts b/packages/nocodb/src/helpers/dbHelpers.ts
@@ -138,17 +138,28 @@ export function _wherePk(
   return where;
 }
 
-export function getCompositePkValue(primaryKeys: Column[], row) {
+export function getCompositePkValue(
+  primaryKeys: Column[],
+  row,
+  option?: {
+    skipSubstitutingColumnIds?: boolean;
+  },
+) {
   if (row === null || row === undefined) {
-    NcError.requiredFieldMissing(primaryKeys.map((c) => c.title).join(','));
+    NcError.requiredFieldMissing(
+      primaryKeys
+        .map((c) => (option?.skipSubstitutingColumnIds ? c.id : c.title))
+        .join(','),
+    );
   }
 
   if (typeof row !== 'object') return row;
 
+  const pkIdOrTitleKey = option?.skipSubstitutingColumnIds ? 'id' : 'title';
   if (primaryKeys.length > 1) {
     return primaryKeys
       .map((c) =>
-        (row[c.title] ?? row[c.column_name])
+        (row[c[pkIdOrTitleKey]] ?? row[c.column_name])
           ?.toString?.()
           .replaceAll('_', '\\_'),
       )
@@ -157,7 +168,7 @@ export function getCompositePkValue(primaryKeys: Column[], row) {
 
   return (
     primaryKeys[0] &&
-    (row[primaryKeys[0].title] ?? row[primaryKeys[0].column_name])
+    (row[primaryKeys[0][pkIdOrTitleKey]] ?? row[primaryKeys[0].column_name])
   );
 }
 

diff --git a/packages/nocodb/src/helpers/getAst.ts b/packages/nocodb/src/helpers/getAst.ts
@@ -58,6 +58,7 @@ const getAst = async (
     extractOrderColumn = false,
     includeSortAndFilterColumns = false,
     includeRowColorColumns = false,
+    skipSubstitutingColumnIds = false,
   }: {
     query?: RequestQuery;
     extractOnlyPrimaries?: boolean;
@@ -73,6 +74,7 @@ const getAst = async (
     extractOrderColumn?: boolean;
     includeSortAndFilterColumns?: boolean;
     includeRowColorColumns?: boolean;
+    skipSubstitutingColumnIds?: boolean;
   },
 ): Promise<{
   ast: Ast;
@@ -83,6 +85,10 @@ const getAst = async (
   dependencyFields.nested = dependencyFields.nested || {};
   dependencyFields.fieldsSet = dependencyFields.fieldsSet || new Set();
 
+  const getFieldKey = (col: Column) => {
+    return skipSubstitutingColumnIds ? col.id : col.title;
+  };
+
   let coverImageId;
   let dependencyFieldsForCalenderView;
   let kanbanGroupColumnId;
@@ -131,9 +137,12 @@ const getAst = async (
   if (extractOnlyPrimaries) {
     const ast: Ast = {
       ...(model.primaryKeys
-        ? model.primaryKeys.reduce((o, pk) => ({ ...o, [pk.title]: 1 }), {})
+        ? model.primaryKeys.reduce(
+            (o, pk) => ({ ...o, [getFieldKey(pk)]: 1 }),
+            {},
+          )
         : {}),
-      ...(model.displayValue ? { [model.displayValue.title]: 1 } : {}),
+      ...(model.displayValue ? { [getFieldKey(model.displayValue)]: 1 } : {}),
     };
     await Promise.all(
       model.primaryKeys.map((c) =>
@@ -150,7 +159,7 @@ const getAst = async (
     const ast: Ast = {
       ...(dependencyFieldsForCalenderView || []).reduce((o, f) => {
         const col = model.columns.find((c) => c.id === f);
-        return { ...o, [col.title]: 1 };
+        return { ...o, [getFieldKey(col)]: 1 };
       }, {}),
     };
 
@@ -215,6 +224,7 @@ const getAst = async (
 
   const ast: Ast = await columns.reduce(async (obj, col: Column) => {
     let value: number | boolean | { [key: string]: any } = 1;
+    // TODO: also get from col.id
     const nestedFields =
       query?.nested?.[col.title]?.fields || query?.nested?.[col.title]?.f;
     if (nestedFields && nestedFields !== '*') {
@@ -333,7 +343,7 @@ const getAst = async (
 
     return {
       ...(await obj),
-      [col.title]: isRequested,
+      [getFieldKey(col)]: isRequested,
     };
   }, Promise.resolve({}));
 

diff --git a/packages/nocodb/src/services/datas.service.ts b/packages/nocodb/src/services/datas.service.ts
@@ -1,6 +1,6 @@
 import { Injectable, Logger } from '@nestjs/common';
 import { isLinksOrLTAR, NcSDKErrorV2 } from 'nocodb-sdk';
-import type { NcApiVersion } from 'nocodb-sdk';
+import { NcApiVersion } from 'nocodb-sdk';
 import type { BaseModelSqlv2 } from '~/db/BaseModelSqlv2';
 import type { PathParams } from '~/helpers/dataHelpers';
 import type { NcContext } from '~/interface/config';
@@ -13,6 +13,7 @@ import { PagedResponseImpl } from '~/helpers/PagedResponse';
 import { Base, Column, Model, Source, View } from '~/models';
 import { nocoExecute } from '~/utils';
 import NcConnectionMgrv2 from '~/utils/common/NcConnectionMgrv2';
+import { QUERY_STRING_FIELD_ID_ON_RESULT } from '~/constants';
 
 @Injectable()
 export class DatasService {
@@ -281,6 +282,9 @@ export class DatasService {
                 throwErrorIfInvalidParams: param.throwErrorIfInvalidParams,
                 ignorePagination: param.ignorePagination,
                 limitOverride: param.limitOverride,
+                skipSubstitutingColumnIds:
+                  context.api_version === NcApiVersion.V3 &&
+                  query?.[QUERY_STRING_FIELD_ID_ON_RESULT] === 'true',
               },
             ),
             {},