resolve the PL/SQL failure tests

Author: jawad-arb123

oracle/common.go

@@ -71,7 +71,7 @@ func getOracleArrayType(values []any) string {
 		}
 		switch v := val.(type) {
 		case bool:
-			arrayType = "TABLE OF BOOLEAN"
+			arrayType = "TABLE OF NUMBER(1)"
 		case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64, float32, float64:
 			arrayType = "TABLE OF NUMBER"
 		case time.Time:
@@ -199,7 +199,7 @@ func createTypedDestination(f *schema.Field) interface{} {
 		return new(string)
 
 	case reflect.Bool:
-		return new(bool)
+		return new(int64)
 
 	case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
 		return new(int64)

oracle/create.go

@@ -582,20 +582,20 @@ func buildBulkMergePLSQL(db *gorm.DB, createValues clause.Values, onConflictClau
 						// Column is a BLOB, return raw bytes; no JSON_SERIALIZE
 						stmt.Vars = append(stmt.Vars, sql.Out{Dest: &godror.Lob{IsClob: false}})
 						plsqlBuilder.WriteString(fmt.Sprintf(
-							"  IF l_affected_records.COUNT > %d THEN :%d := l_affected_records(%d).",
-							rowIdx, outParamIndex+1, rowIdx+1,
+							"  IF l_affected_records.COUNT > %d THEN SELECT l_affected_records(%d).",
+							rowIdx, rowIdx+1,
 						))
 						db.QuoteTo(&plsqlBuilder, column)
-						plsqlBuilder.WriteString("; END IF;\n")
+						plsqlBuilder.WriteString(fmt.Sprintf(" INTO :%d FROM DUAL; END IF;\n", outParamIndex+1))
 					} else {
 						// datatypes.JSON (text-based) -> serialize to CLOB
 						stmt.Vars = append(stmt.Vars, sql.Out{Dest: &godror.Lob{IsClob: true}})
 						plsqlBuilder.WriteString(fmt.Sprintf(
-							"  IF l_affected_records.COUNT > %d THEN :%d := JSON_SERIALIZE(l_affected_records(%d).",
-							rowIdx, outParamIndex+1, rowIdx+1,
+							"  IF l_affected_records.COUNT > %d THEN SELECT JSON_SERIALIZE(l_affected_records(%d).",
+							rowIdx, rowIdx+1,
 						))
 						db.QuoteTo(&plsqlBuilder, column)
-						plsqlBuilder.WriteString(" RETURNING CLOB); END IF;\n")
+						plsqlBuilder.WriteString(fmt.Sprintf(" RETURNING CLOB) INTO :%d FROM DUAL; END IF;\n", outParamIndex+1))
 					}
 				} else {
 					fieldType := createTypedDestination(field)
@@ -608,9 +608,9 @@ func buildBulkMergePLSQL(db *gorm.DB, createValues clause.Values, onConflictClau
 						}
 					}
 					stmt.Vars = append(stmt.Vars, sql.Out{Dest: fieldType})
-					plsqlBuilder.WriteString(fmt.Sprintf("  IF l_affected_records.COUNT > %d THEN :%d := l_affected_records(%d).", rowIdx, outParamIndex+1, rowIdx+1))
+					plsqlBuilder.WriteString(fmt.Sprintf("  IF l_affected_records.COUNT > %d THEN SELECT l_affected_records(%d).", rowIdx, rowIdx+1))
 					db.QuoteTo(&plsqlBuilder, column)
-					plsqlBuilder.WriteString("; END IF;\n")
+					plsqlBuilder.WriteString(fmt.Sprintf(" INTO :%d FROM DUAL; END IF;\n", outParamIndex+1))
 				}
 				outParamIndex++
 			}
@@ -717,15 +717,15 @@ func buildBulkInsertOnlyPLSQL(db *gorm.DB, createValues clause.Values, bindMap p
 						// Column is a BLOB, return raw bytes; no JSON_SERIALIZE
 						stmt.Vars = append(stmt.Vars, sql.Out{Dest: &godror.Lob{IsClob: false}})
 						plsqlBuilder.WriteString(fmt.Sprintf(
-							"  IF l_inserted_records.COUNT > %d THEN :%d := l_inserted_records(%d).%s; END IF;\n",
-							rowIdx, outParamIndex+1, rowIdx+1, quotedColumn,
+							"  IF l_inserted_records.COUNT > %d THEN SELECT l_inserted_records(%d).%s INTO :%d FROM DUAL; END IF;\n",
+							rowIdx, rowIdx+1, quotedColumn, outParamIndex+1,
 						))
 					} else {
 						// datatypes.JSON (text-based) -> serialize to CLOB
 						stmt.Vars = append(stmt.Vars, sql.Out{Dest: &godror.Lob{IsClob: true}})
 						plsqlBuilder.WriteString(fmt.Sprintf(
-							"  IF l_inserted_records.COUNT > %d THEN :%d := JSON_SERIALIZE(l_inserted_records(%d).%s RETURNING CLOB); END IF;\n",
-							rowIdx, outParamIndex+1, rowIdx+1, quotedColumn,
+							"  IF l_inserted_records.COUNT > %d THEN SELECT JSON_SERIALIZE(l_inserted_records(%d).%s RETURNING CLOB) INTO :%d FROM DUAL; END IF;\n",
+							rowIdx, rowIdx+1, quotedColumn, outParamIndex+1,
 						))
 					}
 				} else {
@@ -740,9 +740,10 @@ func buildBulkInsertOnlyPLSQL(db *gorm.DB, createValues clause.Values, bindMap p
 					}
 					stmt.Vars = append(stmt.Vars, sql.Out{Dest: fieldType})
 					plsqlBuilder.WriteString(fmt.Sprintf(
-						"  IF l_inserted_records.COUNT > %d THEN :%d := l_inserted_records(%d).%s; END IF;\n",
-						rowIdx, outParamIndex+1, rowIdx+1, quotedColumn,
+						"  IF l_inserted_records.COUNT > %d THEN SELECT l_inserted_records(%d).%s INTO :%d FROM DUAL; END IF;\n",
+						rowIdx, rowIdx+1, quotedColumn, outParamIndex+1,
 					))
+
 				}
 				outParamIndex++
 			}

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