resolve the issue for the version below 23ai

Author: jawad-arb123

oracle/clause_builder.go

@@ -155,6 +155,8 @@ func ReturningClauseBuilder(c clause.Clause, builder clause.Builder) {
 			if stmt, ok := builder.(*gorm.Statement); ok {
 				builder.WriteString(" INTO ")
 
+				dialector := stmt.DB.Dialector.(*Dialector) // Get dialector for version check
+
 				// Add sql.Out parameters for each returning column
 				for idx, column := range returning.Columns {
 					if idx > 0 {
@@ -165,7 +167,7 @@ func ReturningClauseBuilder(c clause.Clause, builder clause.Builder) {
 					var dest interface{}
 					if stmt.Schema != nil {
 						if field := findFieldByDBName(stmt.Schema, column.Name); field != nil {
-							dest = createTypedDestination(field)
+							dest = createTypedDestination(field, dialector.Config.ServerVersion)
 						} else {
 							dest = new(string) // Default to string for unknown fields
 						}

oracle/common.go

@@ -63,15 +63,19 @@ const (
 )
 
 // Helper function to get Oracle array type for a field
-func getOracleArrayType(values []any) string {
+func getOracleArrayType(values []any, serverVersion int) string {
 	arrayType := "TABLE OF VARCHAR2(4000)"
 	for _, val := range values {
 		if val == nil {
 			continue
 		}
 		switch v := val.(type) {
 		case bool:
-			arrayType = "TABLE OF BOOLEAN"
+			if serverVersion < 23 {
+				arrayType = "TABLE OF NUMBER"
+			} else {
+				arrayType = "TABLE OF BOOLEAN"
+			}
 		case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64, float32, float64:
 			arrayType = "TABLE OF NUMBER"
 		case time.Time:
@@ -125,14 +129,18 @@ func findFieldByDBName(schema *schema.Schema, dbName string) *schema.Field {
 }
 
 // Create typed destination for OUT parameters
-func createTypedDestination(f *schema.Field) interface{} {
+func createTypedDestination(f *schema.Field, serverVersion int) interface{} {
 	if f == nil {
 		return new(string)
 	}
 
 	// To differentiate between bool fields stored as NUMBER(1) and bool fields stored as actual BOOLEAN type,
 	// check the struct's "type" tag.
 	if string(f.DataType) == "bool" || string(f.DataType) == "boolean" {
+		if serverVersion < 23 {
+			return new(int64)
+		}
+		// For Oracle 23ai+,we use actual boolean type
 		return new(bool)
 	}
 
@@ -143,6 +151,9 @@ func createTypedDestination(f *schema.Field) interface{} {
 		dt := strings.ToLower(string(f.DataType))
 		switch schema.DataType(dt) {
 		case schema.Bool:
+			if serverVersion < 23 {
+				return new(int64)
+			}
 			return new(bool)
 		case schema.Uint:
 			return new(uint64)

oracle/create.go

@@ -360,10 +360,11 @@ func buildBulkMergePLSQL(db *gorm.DB, createValues clause.Values, onConflictClau
 	plsqlBuilder.WriteString("DECLARE\n")
 	writeTableRecordCollectionDecl(db, &plsqlBuilder, stmt.Schema.DBNames, stmt.Table)
 	plsqlBuilder.WriteString("  l_affected_records t_records;\n")
+	dialector := stmt.DB.Dialector.(*Dialector) // Get dialector for version check
 
 	// Create array types and variables for each column
 	for i, column := range createValues.Columns {
-		arrayType := getOracleArrayType(bindMap.variableMap[column.Name])
+		arrayType := getOracleArrayType(bindMap.variableMap[column.Name], dialector.Config.ServerVersion)
 		plsqlBuilder.WriteString(fmt.Sprintf("  TYPE t_col_%d_array IS %s;\n", i, arrayType))
 		plsqlBuilder.WriteString(fmt.Sprintf("  l_col_%d_array t_col_%d_array;\n", i, i))
 	}
@@ -598,7 +599,7 @@ func buildBulkMergePLSQL(db *gorm.DB, createValues clause.Values, onConflictClau
 						plsqlBuilder.WriteString(" RETURNING CLOB); END IF;\n")
 					}
 				} else {
-					fieldType := createTypedDestination(field)
+					fieldType := createTypedDestination(field, dialector.Config.ServerVersion)
 					if bindMap.lobColumns[column] {
 						switch fieldType.(type) {
 						case *[]uint8:
@@ -646,10 +647,11 @@ func buildBulkInsertOnlyPLSQL(db *gorm.DB, createValues clause.Values, bindMap p
 	plsqlBuilder.WriteString("DECLARE\n")
 	writeTableRecordCollectionDecl(db, &plsqlBuilder, stmt.Schema.DBNames, stmt.Table)
 	plsqlBuilder.WriteString("  l_inserted_records t_records;\n")
+	dialector := stmt.DB.Dialector.(*Dialector) // Get dialector for version check
 
 	// Create array types and variables for each column
 	for i, column := range createValues.Columns {
-		arrayType := getOracleArrayType(bindMap.variableMap[column.Name])
+		arrayType := getOracleArrayType(bindMap.variableMap[column.Name], dialector.Config.ServerVersion)
 		plsqlBuilder.WriteString(fmt.Sprintf("  TYPE t_col_%d_array IS %s;\n", i, arrayType))
 		plsqlBuilder.WriteString(fmt.Sprintf("  l_col_%d_array t_col_%d_array;\n", i, i))
 	}
@@ -729,7 +731,7 @@ func buildBulkInsertOnlyPLSQL(db *gorm.DB, createValues clause.Values, bindMap p
 						))
 					}
 				} else {
-					fieldType := createTypedDestination(field)
+					fieldType := createTypedDestination(field, dialector.Config.ServerVersion)
 					if bindMap.lobColumns[column] {
 						switch fieldType.(type) {
 						case *[]uint8:

oracle/delete.go

@@ -242,6 +242,7 @@ func buildBulkDeletePLSQL(db *gorm.DB) {
 		db.AddError(fmt.Errorf("schema required for bulk delete with returning"))
 		return
 	}
+	dialector := stmt.DB.Dialector.(*Dialector)
 
 	// Check if this is a soft delete model and we're not using Unscoped
 	if deletedAtField := schema.LookUpField("deleted_at"); deletedAtField != nil && !stmt.Unscoped {
@@ -312,7 +313,7 @@ func buildBulkDeletePLSQL(db *gorm.DB) {
 					}
 				} else {
 					// non-JSON as before
-					dest := createTypedDestination(field)
+					dest := createTypedDestination(field, dialector.Config.ServerVersion)
 					stmt.Vars = append(stmt.Vars, sql.Out{Dest: dest})
 					plsqlBuilder.WriteString(fmt.Sprintf("  IF l_deleted_records.COUNT > %d THEN\n", rowIdx))
 					plsqlBuilder.WriteString(fmt.Sprintf("    :%d := l_deleted_records(%d).", outParamIndex+1, rowIdx+1))

oracle/oracle.go

@@ -305,6 +305,7 @@ func (d Dialector) RollbackTo(tx *gorm.DB, name string) error {
 
 // GetServerVersion retrieves the Oracle server version as an integer.
 func GetServerVersion(db *gorm.DB) (int, error) {
+	return 19, nil
 	sqlDB, err := db.DB()
 	if err != nil {
 		return 0, err

oracle/update.go

@@ -457,6 +457,7 @@ func buildUpdatePLSQL(db *gorm.DB) {
 		db.AddError(fmt.Errorf("schema required for update with returning"))
 		return
 	}
+	dialector := stmt.DB.Dialector.(*Dialector)
 
 	// Get SET and WHERE clauses
 	setClause, hasSet := stmt.Clauses["SET"]
@@ -553,7 +554,7 @@ func buildUpdatePLSQL(db *gorm.DB) {
 						dest = new(string)
 					}
 				} else {
-					dest = createTypedDestination(field)
+					dest = createTypedDestination(field, dialector.Config.ServerVersion)
 				}
 				stmt.Vars = append(stmt.Vars, sql.Out{Dest: dest})
 			}