@ -632,7 +632,7 @@ class BaseModelSqlv2 {
args . column_name . split ( ',' ) . map ( async ( col ) = > { args . column_name . split ( ',' ) . map ( async ( col ) = > {
let column = cols . find ( ( c ) = > c . column_name === col || c . title === col ) ; let column = cols . find ( ( c ) = > c . column_name === col || c . title === col ) ;
if ( ! column ) { if ( ! column ) {
throw NcError . notFound ( 'Column not found' ) ; throw NcError . fieldNotFound ( col ) ;
} }
// if qrCode or Barcode replace it with value column nd keep the alias
// if qrCode or Barcode replace it with value column nd keep the alias
@ -851,7 +851,7 @@ class BaseModelSqlv2 {
( c ) = > c . column_name === col || c . title === col , ( c ) = > c . column_name === col || c . title === col ,
) ; ) ;
if ( ! column ) { if ( ! column ) {
throw NcError . notFound ( 'Column not found' ) ; throw NcError . fieldNotFound ( col ) ;
} }
// if qrCode or Barcode replace it with value column nd keep the alias
// if qrCode or Barcode replace it with value column nd keep the alias
@ -1805,6 +1805,56 @@ class BaseModelSqlv2 {
? . count ; ? . count ;
} }
// todo: naming & optimizing
public async countExcludedOneToOneChildren (
{ colId , cid = null } ,
args ,
) : Promise < any > {
const { where } = this . _getListArgs ( args as any ) ;
const relColumn = ( await this . model . getColumns ( ) ) . find (
( c ) = > c . id === colId ,
) ;
const relColOptions =
( await relColumn . getColOptions ( ) ) as LinkToAnotherRecordColumn ;
const rcn = ( await relColOptions . getParentColumn ( ) ) . column_name ;
const parentTable = await (
await relColOptions . getParentColumn ( )
) . getModel ( ) ;
const cn = ( await relColOptions . getChildColumn ( ) ) . column_name ;
const childTable = await ( await relColOptions . getChildColumn ( ) ) . getModel ( ) ;
const childTn = this . getTnPath ( childTable ) ;
const parentTn = this . getTnPath ( parentTable ) ;
const rtn = parentTn ;
const tn = childTn ;
await childTable . getColumns ( ) ;
// one-to-one relation is combination of both hm and bt to identify table which have
// foreign key column(similar to bt) we are adding a boolean flag `bt` under meta
const isBt = relColumn . meta ? . bt ;
const qb = this . dbDriver ( isBt ? rtn : tn )
. where ( ( qb ) = > {
qb . whereNotIn (
isBt ? rcn : cn ,
this . dbDriver ( isBt ? tn : rtn )
. select ( isBt ? cn : rcn )
. where ( _wherePk ( ( isBt ? childTable : parentTable ) . primaryKeys , cid ) )
. whereNotNull ( isBt ? cn : rcn ) ,
) . orWhereNull ( isBt ? rcn : cn ) ;
} )
. count ( ` * ` , { as : 'count' } ) ;
const aliasColObjMap = await parentTable . getAliasColObjMap ( ) ;
const filterObj = extractFilterFromXwhere ( where , aliasColObjMap ) ;
await conditionV2 ( this , filterObj , qb ) ;
return ( await this . execAndParse ( qb , null , { raw : true , first : true } ) )
? . count ;
}
// todo: naming & optimizing
// todo: naming & optimizing
public async getBtChildrenExcludedList ( public async getBtChildrenExcludedList (
{ colId , cid = null } , { colId , cid = null } ,
@ -1877,6 +1927,85 @@ class BaseModelSqlv2 {
} ) ; } ) ;
} }
// todo: naming & optimizing
public async getExcludedOneToOneChildrenList (
{ colId , cid = null } ,
args ,
) : Promise < any > {
const { where , . . . rest } = this . _getListArgs ( args as any ) ;
const relColumn = ( await this . model . getColumns ( ) ) . find (
( c ) = > c . id === colId ,
) ;
const relColOptions =
( await relColumn . getColOptions ( ) ) as LinkToAnotherRecordColumn ;
const rcn = ( await relColOptions . getParentColumn ( ) ) . column_name ;
const parentTable = await (
await relColOptions . getParentColumn ( )
) . getModel ( ) ;
const cn = ( await relColOptions . getChildColumn ( ) ) . column_name ;
const childTable = await ( await relColOptions . getChildColumn ( ) ) . getModel ( ) ;
const parentModel = await Model . getBaseModelSQL ( {
dbDriver : this.dbDriver ,
model : parentTable ,
} ) ;
const childModel = await Model . getBaseModelSQL ( {
dbDriver : this.dbDriver ,
model : childTable ,
} ) ;
const rtn = this . getTnPath ( parentTable ) ;
const tn = this . getTnPath ( childTable ) ;
await childTable . getColumns ( ) ;
// one-to-one relation is combination of both hm and bt to identify table which have
// foreign key column(similar to bt) we are adding a boolean flag `bt` under meta
const isBt = relColumn . meta ? . bt ;
const qb = this . dbDriver ( isBt ? rtn : tn ) . where ( ( qb ) = > {
qb . whereNotIn (
isBt ? rcn : cn ,
this . dbDriver ( isBt ? tn : rtn )
. select ( isBt ? cn : rcn )
. where ( _wherePk ( ( isBt ? childTable : parentTable ) . primaryKeys , cid ) )
. whereNotNull ( isBt ? cn : rcn ) ,
) . orWhereNull ( isBt ? rcn : cn ) ;
} ) ;
if ( + rest ? . shuffle ) {
await this . shuffle ( { qb } ) ;
}
await ( isBt ? parentModel : childModel ) . selectObject ( { qb } ) ;
const aliasColObjMap = await parentTable . getAliasColObjMap ( ) ;
const filterObj = extractFilterFromXwhere ( where , aliasColObjMap ) ;
await conditionV2 ( this , filterObj , qb ) ;
// sort by primary key if not autogenerated string
// if autogenerated string sort by created_at column if present
if ( parentTable . primaryKey && parentTable . primaryKey . ai ) {
qb . orderBy ( parentTable . primaryKey . column_name ) ;
} else if (
parentTable . columns . find ( ( c ) = > c . column_name === 'created_at' )
) {
qb . orderBy ( 'created_at' ) ;
}
applyPaginate ( qb , rest ) ;
const proto = await ( isBt ? parentModel : childModel ) . getProto ( ) ;
const data = await this . execAndParse (
qb ,
await ( isBt ? parentTable : childTable ) . getColumns ( ) ,
) ;
return data . map ( ( c ) = > {
c . __proto__ = proto ;
return c ;
} ) ;
}
protected async getSelectQueryBuilderForFormula ( protected async getSelectQueryBuilderForFormula (
column : Column < any > , column : Column < any > ,
tableAlias? : string , tableAlias? : string ,
@ -2106,6 +2235,141 @@ class BaseModelSqlv2 {
return await readLoader . load ( this ? . [ cCol ? . title ] ) ; return await readLoader . load ( this ? . [ cCol ? . title ] ) ;
} ; } ;
// todo : handle mm
// todo : handle mm
} else if ( colOptions . type === 'oo' ) {
const isBt = column . meta ? . bt ;
if ( isBt ) {
// @ts-ignore
const colOptions =
( await column . getColOptions ( ) ) as LinkToAnotherRecordColumn ;
const pCol = await Column . get ( {
colId : colOptions.fk_parent_column_id ,
} ) ;
const cCol = await Column . get ( {
colId : colOptions.fk_child_column_id ,
} ) ;
// use dataloader to get batches of parent data together rather than getting them individually
// it takes individual keys and callback is invoked with an array of values and we can get the
// result for all those together and return the value in the same order as in the array
// this way all parents data extracted together
const readLoader = new DataLoader (
async ( _ids : string [ ] ) = > {
// handle binary(16) foreign keys
const ids = _ids . map ( ( id ) = > {
if ( pCol . ct !== 'binary(16)' ) return id ;
// Cast the id to string.
const idAsString = id + '' ;
// Check if the id is a UUID and the column is binary(16)
const isUUIDBinary16 =
idAsString . length === 36 || idAsString . length === 32 ;
// If the id is a UUID and the column is binary(16), convert the id to a Buffer. Otherwise, return null to indicate that the id is not a UUID.
const idAsUUID = isUUIDBinary16
? idAsString . length === 32
? idAsString . replace (
/(.{8})(.{4})(.{4})(.{4})(.{12})/ ,
'$1-$2-$3-$4-$5' ,
)
: idAsString
: null ;
return idAsUUID
? Buffer . from ( idAsUUID . replace ( /-/g , '' ) , 'hex' )
: id ;
} ) ;
const data = await (
await Model . getBaseModelSQL ( {
id : pCol.fk_model_id ,
dbDriver : this.dbDriver ,
} )
) . list (
{
fieldsSet : ( readLoader as any ) . args ? . fieldsSet ,
filterArr : [
new Filter ( {
id : null ,
fk_column_id : pCol.id ,
fk_model_id : pCol.fk_model_id ,
value : ids as any [ ] ,
comparison_op : 'in' ,
} ) ,
] ,
} ,
{
ignoreViewFilterAndSort : true ,
ignorePagination : true ,
} ,
) ;
const groupedList = groupBy ( data , pCol . title ) ;
return _ids . map (
async ( id : string ) = > groupedList ? . [ id ] ? . [ 0 ] ,
) ;
} ,
{
cache : false ,
} ,
) ;
// defining BelongsTo read resolver method
proto [ column . title ] = async function ( args? : any ) {
if (
this ? . [ cCol ? . title ] === null ||
this ? . [ cCol ? . title ] === undefined
)
return null ;
( readLoader as any ) . args = args ;
return await readLoader . load ( this ? . [ cCol ? . title ] ) ;
} ;
} else {
const listLoader = new DataLoader (
async ( ids : string [ ] ) = > {
if ( ids . length > 1 ) {
const data = await this . multipleHmList (
{
colId : column.id ,
ids ,
} ,
( listLoader as any ) . args ,
) ;
return ids . map ( ( id : string ) = >
data [ id ] ? data [ id ] ? . [ 0 ] : null ,
) ;
} else {
return [
(
await this . hmList (
{
colId : column.id ,
id : ids [ 0 ] ,
} ,
( listLoader as any ) . args ,
)
) ? . [ 0 ] ? ? null ,
] ;
}
} ,
{
cache : false ,
} ,
) ;
const self : BaseModelSqlv2 = this ;
proto [
column . uidt === UITypes . Links
? ` _nc_lk_ ${ column . title } `
: column . title
] = async function ( args ) : Promise < any > {
( listLoader as any ) . args = args ;
return listLoader . load (
getCompositePk ( self . model . primaryKeys , this ) ,
) ;
} ;
}
} }
} }
break ; break ;
@ -2806,7 +3070,7 @@ class BaseModelSqlv2 {
const nestedCols = ( await this . model . getColumns ( ) ) . filter ( ( c ) = > const nestedCols = ( await this . model . getColumns ( ) ) . filter ( ( c ) = >
isLinksOrLTAR ( c ) , isLinksOrLTAR ( c ) ,
) ; ) ;
const postInsertOps = await this . prepareNestedLinkQb ( { const { postInsertOps , preInsertOps } = await this . prepareNestedLinkQb ( {
nestedCols , nestedCols ,
data , data ,
insertObj , insertObj ,
@ -2818,6 +3082,8 @@ class BaseModelSqlv2 {
await this . prepareNocoData ( insertObj , true , cookie ) ; await this . prepareNocoData ( insertObj , true , cookie ) ;
await Promise . all ( preInsertOps . map ( ( f ) = > f ( this . dbDriver ) ) ) ;
let response ; let response ;
const query = this . dbDriver ( this . tnPath ) . insert ( insertObj ) ; const query = this . dbDriver ( this . tnPath ) . insert ( insertObj ) ;
@ -2958,6 +3224,7 @@ class BaseModelSqlv2 {
insertObj : Record < string , any > ; insertObj : Record < string , any > ;
} ) { } ) {
const postInsertOps : ( ( rowId : any , trx? : any ) = > Promise < void > ) [ ] = [ ] ; const postInsertOps : ( ( rowId : any , trx? : any ) = > Promise < void > ) [ ] = [ ] ;
const preInsertOps : ( ( trx? : any ) = > Promise < void > ) [ ] = [ ] ;
for ( const col of nestedCols ) { for ( const col of nestedCols ) {
if ( col . title in data ) { if ( col . title in data ) {
const colOptions = await col . getColOptions < LinkToAnotherRecordColumn > ( ) ; const colOptions = await col . getColOptions < LinkToAnotherRecordColumn > ( ) ;
@ -2981,6 +3248,45 @@ class BaseModelSqlv2 {
insertObj [ childCol . column_name ] = nestedData ? . [ parentCol . title ] ; insertObj [ childCol . column_name ] = nestedData ? . [ parentCol . title ] ;
} }
break ; break ;
case RelationTypes . ONE_TO_ONE :
{
const isBt = col . meta ? . bt ;
const childCol = await colOptions . getChildColumn ( ) ;
const childModel = await childCol . getModel ( ) ;
await childModel . getColumns ( ) ;
if ( isBt ) {
// todo: unlink the ref record
preInsertOps . push ( async ( trx : any = this . dbDriver ) = > {
await trx ( this . getTnPath ( childModel . table_name ) )
. update ( {
[ childCol . column_name ] : null ,
} )
. where (
childCol . column_name ,
nestedData [ childModel . primaryKey . title ] ,
) ;
} ) ;
if ( typeof nestedData !== 'object' ) continue ;
const childCol = await colOptions . getChildColumn ( ) ;
const parentCol = await colOptions . getParentColumn ( ) ;
insertObj [ childCol . column_name ] = nestedData ? . [ parentCol . title ] ;
} else {
postInsertOps . push ( async ( rowId , trx : any = this . dbDriver ) = > {
await trx ( this . getTnPath ( childModel . table_name ) )
. update ( {
[ childCol . column_name ] : rowId ,
} )
. where (
childModel . primaryKey . column_name ,
nestedData [ childModel . primaryKey . title ] ,
) ;
} ) ;
}
}
break ;
case RelationTypes . HAS_MANY : case RelationTypes . HAS_MANY :
{ {
if ( ! Array . isArray ( nestedData ) ) continue ; if ( ! Array . isArray ( nestedData ) ) continue ;
@ -3033,7 +3339,7 @@ class BaseModelSqlv2 {
} }
} }
} }
return postInsertOps ; return { postInsertOps , preInsertOps } ;
} }
async bulkInsert ( async bulkInsert (
@ -3061,6 +3367,7 @@ class BaseModelSqlv2 {
// TODO: ag column handling for raw bulk insert
// TODO: ag column handling for raw bulk insert
const insertDatas = raw ? datas : [ ] ; const insertDatas = raw ? datas : [ ] ;
let postInsertOps : ( ( rowId : any , trx? : any ) = > Promise < void > ) [ ] = [ ] ; let postInsertOps : ( ( rowId : any , trx? : any ) = > Promise < void > ) [ ] = [ ] ;
let preInsertOps : ( ( trx? : any ) = > Promise < void > ) [ ] = [ ] ;
let aiPkCol : Column ; let aiPkCol : Column ;
let agPkCol : Column ; let agPkCol : Column ;
@ -3209,11 +3516,14 @@ class BaseModelSqlv2 {
// prepare nested link data for insert only if it is single record insertion
// prepare nested link data for insert only if it is single record insertion
if ( isSingleRecordInsertion ) { if ( isSingleRecordInsertion ) {
postInsertOp s= await this . prepareNestedLinkQb ( { const operation s= await this . prepareNestedLinkQb ( {
nestedCols , nestedCols ,
data : d , data : d ,
insertObj , insertObj ,
} ) ; } ) ;
postInsertOps = operations . postInsertOps ;
preInsertOps = operations . preInsertOps ;
} }
insertDatas . push ( insertObj ) ; insertDatas . push ( insertObj ) ;
@ -3244,6 +3554,8 @@ class BaseModelSqlv2 {
} }
} }
await Promise . all ( preInsertOps . map ( ( f ) = > f ( trx ) ) ) ;
let responses ; let responses ;
// insert one by one as fallback to get ids for sqlite and mysql
// insert one by one as fallback to get ids for sqlite and mysql
@ -3371,9 +3683,7 @@ class BaseModelSqlv2 {
if ( ! pkValues ) { if ( ! pkValues ) {
// throw or skip if no pk provided
// throw or skip if no pk provided
if ( throwExceptionIfNotExist ) { if ( throwExceptionIfNotExist ) {
NcError . unprocessableEntity ( NcError . recordNotFound ( JSON . stringify ( pkValues ) ) ;
` Record with pk ${ JSON . stringify ( pkValues ) } not found ` ,
) ;
} }
continue ; continue ;
} }
@ -3384,9 +3694,7 @@ class BaseModelSqlv2 {
if ( ! oldRecord ) { if ( ! oldRecord ) {
// throw or skip if no record found
// throw or skip if no record found
if ( throwExceptionIfNotExist ) { if ( throwExceptionIfNotExist ) {
NcError . unprocessableEntity ( NcError . recordNotFound ( JSON . stringify ( pkValues ) ) ;
` Record with pk ${ JSON . stringify ( pkValues ) } not found ` ,
) ;
} }
continue ; continue ;
} }
@ -3541,9 +3849,7 @@ class BaseModelSqlv2 {
if ( ! pkValues ) { if ( ! pkValues ) {
// throw or skip if no pk provided
// throw or skip if no pk provided
if ( throwExceptionIfNotExist ) { if ( throwExceptionIfNotExist ) {
NcError . unprocessableEntity ( NcError . recordNotFound ( JSON . stringify ( pkValues ) ) ;
` Record with pk ${ JSON . stringify ( pkValues ) } not found ` ,
) ;
} }
continue ; continue ;
} }
@ -3552,9 +3858,7 @@ class BaseModelSqlv2 {
if ( ! deletedRecord ) { if ( ! deletedRecord ) {
// throw or skip if no record found
// throw or skip if no record found
if ( throwExceptionIfNotExist ) { if ( throwExceptionIfNotExist ) {
NcError . unprocessableEntity ( NcError . recordNotFound ( JSON . stringify ( pkValues ) ) ;
` Record with pk ${ JSON . stringify ( pkValues ) } not found ` ,
) ;
} }
continue ; continue ;
} }
@ -4118,7 +4422,7 @@ class BaseModelSqlv2 {
! column || ! column ||
! [ UITypes . LinkToAnotherRecord , UITypes . Links ] . includes ( column . uidt ) ! [ UITypes . LinkToAnotherRecord , UITypes . Links ] . includes ( column . uidt )
) )
NcError . notFound ( 'Column not found' ) ; NcError . fieldNotFound ( colId ) ;
const colOptions = await column . getColOptions < LinkToAnotherRecordColumn > ( ) ; const colOptions = await column . getColOptions < LinkToAnotherRecordColumn > ( ) ;
@ -4245,6 +4549,54 @@ class BaseModelSqlv2 {
} ) ; } ) ;
} }
break ; break ;
case RelationTypes . ONE_TO_ONE :
{
const isBt = column . meta ? . bt ;
// todo: unlink if it's already mapped
// unlink already mapped record if any
await this . execAndParse (
this . dbDriver ( childTn )
. where ( {
[ childColumn . column_name ] : this . dbDriver . from (
this . dbDriver ( parentTn )
. select ( parentColumn . column_name )
. where (
_wherePk ( parentTable . primaryKeys , isBt ? childId : rowId ) ,
)
. first ( )
. as ( '___cn_alias' ) ,
) ,
} )
. update ( { [ childColumn . column_name ] : null } ) ,
null ,
{ raw : true } ,
) ;
await this . execAndParse (
this . dbDriver ( childTn )
. update ( {
[ childColumn . column_name ] : this . dbDriver . from (
this . dbDriver ( parentTn )
. select ( parentColumn . column_name )
. where (
_wherePk ( parentTable . primaryKeys , isBt ? childId : rowId ) ,
)
. first ( )
. as ( '___cn_alias' ) ,
) ,
} )
. where ( _wherePk ( childTable . primaryKeys , isBt ? rowId : childId ) ) ,
null ,
{ raw : true } ,
) ;
await this . updateLastModified ( {
model : parentTable ,
rowIds : [ childId ] ,
cookie ,
} ) ;
}
break ;
} }
const response = await this . readByPk ( const response = await this . readByPk (
@ -4290,7 +4642,7 @@ class BaseModelSqlv2 {
! column || ! column ||
! [ UITypes . LinkToAnotherRecord , UITypes . Links ] . includes ( column . uidt ) ! [ UITypes . LinkToAnotherRecord , UITypes . Links ] . includes ( column . uidt )
) )
NcError . notFound ( 'Column not found' ) ; NcError . fieldNotFound ( colId ) ;
const colOptions = await column . getColOptions < LinkToAnotherRecordColumn > ( ) ; const colOptions = await column . getColOptions < LinkToAnotherRecordColumn > ( ) ;
@ -4395,6 +4747,24 @@ class BaseModelSqlv2 {
} ) ; } ) ;
} }
break ; break ;
case RelationTypes . ONE_TO_ONE :
{
const isBt = column . meta ? . bt ;
await this . execAndParse (
this . dbDriver ( childTn )
. where ( _wherePk ( childTable . primaryKeys , isBt ? rowId : childId ) )
. update ( { [ childColumn . column_name ] : null } ) ,
null ,
{ raw : true } ,
) ;
await this . updateLastModified ( {
model : parentTable ,
rowIds : [ childId ] ,
cookie ,
} ) ;
}
break ;
} }
const newData = await this . readByPk ( const newData = await this . readByPk (
@ -4440,9 +4810,9 @@ class BaseModelSqlv2 {
. getColumns ( ) . getColumns ( )
. then ( ( cols ) = > cols ? . find ( ( col ) = > col . id === args . groupColumnId ) ) ; . then ( ( cols ) = > cols ? . find ( ( col ) = > col . id === args . groupColumnId ) ) ;
if ( ! column ) NcError . notFound ( 'Column not found' ) ; if ( ! column ) NcError . fieldNotFound ( args . groupColumnId ) ;
if ( isVirtualCol ( column ) ) if ( isVirtualCol ( column ) )
NcError . notImplemented ( 'Grouping for virtual columns not implemented ' ) ; NcError . notImplemented ( 'Grouping for virtual columns' ) ;
// extract distinct group column values
// extract distinct group column values
let groupingValues : Set < any > ; let groupingValues : Set < any > ;
@ -4602,9 +4972,9 @@ class BaseModelSqlv2 {
. getColumns ( ) . getColumns ( )
. then ( ( cols ) = > cols ? . find ( ( col ) = > col . id === args . groupColumnId ) ) ; . then ( ( cols ) = > cols ? . find ( ( col ) = > col . id === args . groupColumnId ) ) ;
if ( ! column ) NcError . notFound ( 'Column not found' ) ; if ( ! column ) NcError . fieldNotFound ( args . groupColumnId ) ;
if ( isVirtualCol ( column ) ) if ( isVirtualCol ( column ) )
NcError . notImplemented ( 'Grouping for virtual columns not implemented ' ) ; NcError . notImplemented ( 'Grouping for virtual columns' ) ;
const qb = this . dbDriver ( this . tnPath ) const qb = this . dbDriver ( this . tnPath )
. count ( '*' , { as : 'count' } ) . count ( '*' , { as : 'count' } )
@ -4767,7 +5137,11 @@ class BaseModelSqlv2 {
} }
idToAliasMap [ col . id ] = col . title ; idToAliasMap [ col . id ] = col . title ;
if ( col . colOptions ? . type === 'bt' ) { if (
[ RelationTypes . BELONGS_TO , RelationTypes . ONE_TO_ONE ] . includes (
col . colOptions ? . type ,
)
) {
btMap [ col . id ] = true ; btMap [ col . id ] = true ;
const btData = Object . values ( data ) . find ( const btData = Object . values ( data ) . find (
( d ) = > d [ col . id ] && Object . keys ( d [ col . id ] ) , ( d ) = > d [ col . id ] && Object . keys ( d [ col . id ] ) ,
@ -5200,7 +5574,7 @@ class BaseModelSqlv2 {
async addLinks ( { async addLinks ( {
cookie , cookie ,
childIds , childIds : _childIds ,
colId , colId ,
rowId , rowId ,
} : { } : {
@ -5212,8 +5586,7 @@ class BaseModelSqlv2 {
const columns = await this . model . getColumns ( ) ; const columns = await this . model . getColumns ( ) ;
const column = columns . find ( ( c ) = > c . id === colId ) ; const column = columns . find ( ( c ) = > c . id === colId ) ;
if ( ! column || ! isLinksOrLTAR ( column ) ) if ( ! column || ! isLinksOrLTAR ( column ) ) NcError . fieldNotFound ( colId ) ;
NcError . notFound ( ` Link column ${ colId } not found ` ) ;
const row = await this . readByPk ( const row = await this . readByPk (
rowId , rowId ,
@ -5224,10 +5597,10 @@ class BaseModelSqlv2 {
// validate rowId
// validate rowId
if ( ! row ) { if ( ! row ) {
NcError . n otFound( ` Record with id ' ${ rowId } ' not found ` ) ; NcError . recordN otFound( rowId ) ;
} }
if ( ! childIds . length ) return ; if ( ! _ childIds. length ) return ;
const colOptions = await column . getColOptions < LinkToAnotherRecordColumn > ( ) ; const colOptions = await column . getColOptions < LinkToAnotherRecordColumn > ( ) ;
@ -5241,7 +5614,39 @@ class BaseModelSqlv2 {
const childTn = this . getTnPath ( childTable ) ; const childTn = this . getTnPath ( childTable ) ;
const parentTn = this . getTnPath ( parentTable ) ; const parentTn = this . getTnPath ( parentTable ) ;
switch ( colOptions . type ) { let relationType = colOptions . type ;
let childIds = _childIds ;
if ( relationType === RelationTypes . ONE_TO_ONE ) {
relationType = column . meta ? . bt
? RelationTypes . BELONGS_TO
: RelationTypes . HAS_MANY ;
childIds = childIds . slice ( 0 , 1 ) ;
// unlink
await this . execAndParse (
this . dbDriver ( childTn )
. where ( {
[ childColumn . column_name ] : this . dbDriver . from (
this . dbDriver ( parentTn )
. select ( parentColumn . column_name )
. where (
_wherePk (
parentTable . primaryKeys ,
column . meta ? . bt ? childIds [ 0 ] : rowId ,
) ,
)
. first ( )
. as ( '___cn_alias' ) ,
) ,
} )
. update ( { [ childColumn . column_name ] : null } ) ,
null ,
{ raw : true } ,
) ;
}
switch ( relationType ) {
case RelationTypes . MANY_TO_MANY : case RelationTypes . MANY_TO_MANY :
{ {
const vChildCol = await colOptions . getMMChildColumn ( ) ; const vChildCol = await colOptions . getMMChildColumn ( ) ;
@ -5303,11 +5708,7 @@ class BaseModelSqlv2 {
! childRows . find ( ( r ) = > r [ parentColumn . column_name ] === id ) , ! childRows . find ( ( r ) = > r [ parentColumn . column_name ] === id ) ,
) ; ) ;
NcError . unprocessableEntity ( NcError . recordNotFound ( extractIds ( missingIds ) ) ;
` Child record with id [ ${ extractIdsString (
missingIds ,
) } ] not found ` ,
) ;
} }
insertData = childRows insertData = childRows
@ -5380,11 +5781,7 @@ class BaseModelSqlv2 {
! childRows . find ( ( r ) = > r [ parentColumn . column_name ] === id ) , ! childRows . find ( ( r ) = > r [ parentColumn . column_name ] === id ) ,
) ; ) ;
NcError . unprocessableEntity ( NcError . recordNotFound ( extractIds ( missingIds ) ) ;
` Child record with id [ ${ extractIdsString (
missingIds ,
) } ] not found ` ,
) ;
} }
} }
const updateQb = this . dbDriver ( childTn ) . update ( { const updateQb = this . dbDriver ( childTn ) . update ( {
@ -5438,12 +5835,7 @@ class BaseModelSqlv2 {
} ) ; } ) ;
if ( ! childRow ) { if ( ! childRow ) {
NcError . unprocessableEntity ( NcError . recordNotFound ( extractIds ( childIds , true ) ) ;
` Child record with id [ ${ extractIdsString (
childIds ,
true ,
) } ] not found ` ,
) ;
} }
} }
@ -5499,8 +5891,7 @@ class BaseModelSqlv2 {
const columns = await this . model . getColumns ( ) ; const columns = await this . model . getColumns ( ) ;
const column = columns . find ( ( c ) = > c . id === colId ) ; const column = columns . find ( ( c ) = > c . id === colId ) ;
if ( ! column || ! isLinksOrLTAR ( column ) ) if ( ! column || ! isLinksOrLTAR ( column ) ) NcError . fieldNotFound ( colId ) ;
NcError . notFound ( ` Link column ${ colId } not found ` ) ;
const row = await this . readByPk ( const row = await this . readByPk (
rowId , rowId ,
@ -5511,7 +5902,7 @@ class BaseModelSqlv2 {
// validate rowId
// validate rowId
if ( ! row ) { if ( ! row ) {
NcError . n otFound( ` Record with id ' ${ rowId } ' not found ` ) ; NcError . recordN otFound( rowId ) ;
} }
if ( ! childIds . length ) return ; if ( ! childIds . length ) return ;
@ -5585,11 +5976,7 @@ class BaseModelSqlv2 {
) , ) ,
) ; ) ;
NcError . unprocessableEntity ( NcError . recordNotFound ( extractIds ( missingIds ) ) ;
` Child record with id [ ${ extractIdsString (
missingIds ,
) } ] not found ` ,
) ;
} }
} }
@ -5672,11 +6059,7 @@ class BaseModelSqlv2 {
) , ) ,
) ; ) ;
NcError . unprocessableEntity ( NcError . recordNotFound ( extractIds ( missingIds ) ) ;
` Child record with id [ ${ extractIdsString (
missingIds ,
) } ] not found ` ,
) ;
} }
} }
@ -5734,12 +6117,7 @@ class BaseModelSqlv2 {
} ) ; } ) ;
if ( ! childRow ) { if ( ! childRow ) {
NcError . unprocessableEntity ( NcError . recordNotFound ( extractIds ( childIds , true ) ) ;
` Child record with id [ ${ extractIdsString (
childIds ,
true ,
) } ] not found ` ,
) ;
} }
} }
@ -5799,7 +6177,7 @@ class BaseModelSqlv2 {
// validate rowId
// validate rowId
if ( ! row ) { if ( ! row ) {
NcError . n otFound( ` Record with id ${ id } not found ` ) ; NcError . recordN otFound( id ) ;
} }
const parentCol = await ( const parentCol = await (
@ -6087,7 +6465,7 @@ export function extractSortsObject(
else sort . fk_column_id = aliasColObjMap [ s . replace ( /^\+/ , '' ) ] ? . id ; else sort . fk_column_id = aliasColObjMap [ s . replace ( /^\+/ , '' ) ] ? . id ;
if ( throwErrorIfInvalid && ! sort . fk_column_id ) if ( throwErrorIfInvalid && ! sort . fk_column_id )
NcError . unprocessableEntity ( ` Invalid field: ${ s . replace ( /^[+-]/ , '' ) } ` ) ; NcError . fieldNotFound ( s . replace ( /^[+-]/ , '' ) ) ;
return new Sort ( sort ) ; return new Sort ( sort ) ;
} ) ; } ) ;
@ -6258,7 +6636,7 @@ export function extractCondition(
validateFilterComparison ( aliasColObjMap [ alias ] . uidt , op , sub_op ) ; validateFilterComparison ( aliasColObjMap [ alias ] . uidt , op , sub_op ) ;
} else if ( throwErrorIfInvalid ) { } else if ( throwErrorIfInvalid ) {
NcError . unprocessableEntity ( ` Invalid field: ${ alias } ` ) ; NcError . invalidFilter ( str ) ;
} }
return new Filter ( { return new Filter ( {
@ -6414,13 +6792,13 @@ export function getListArgs(
return obj ; return obj ;
} }
function extractIdsString ( function extractIds (
childIds : ( string | number | Record < string , any > ) [ ] , childIds : ( string | number | Record < string , any > ) [ ] ,
isBt = false , isBt = false ,
) { ) {
return ( isBt ? childIds . slice ( 0 , 1 ) : childIds ) return ( isBt ? childIds . slice ( 0 , 1 ) : childIds ) . map ( ( r ) = >
. map ( ( r ) = > ( typeof r === 'object' ? JSON . stringify ( r ) : r ) ) typeof r === 'object' ? JSON . stringify ( r ) : ` ${ r } ` ,
. join ( ', ' ) ; ) ;
} }
export { BaseModelSqlv2 } ; export { BaseModelSqlv2 } ;
Pranav C
8 months ago
committed by
GitHub
