以下是一个示例代码，演示如何使用Apache NiFi将SQL行合并为JSON：

首先，需要创建一个数据流，将SQL查询的结果作为输入。在数据流中，需要使用一个ExecuteSQL流程处理器来执行SQL查询。配置ExecuteSQL流程处理器的属性，包括数据库连接池服务、查询语句和查询参数。

接下来，使用一个ConvertRecord流程处理器来将查询结果转换为JSON格式。在ConvertRecord流程处理器的属性中，配置输入和输出的记录读取器和写入器，将输入的记录读取器设置为AvroReader，输出的记录写入器设置为JsonRecordSetWriter。此外，还需要配置记录转换策略，将SQL行转换为JSON。

最后，使用一个PutFile流程处理器将转换后的JSON数据写入文件。在PutFile流程处理器的属性中，配置目标文件路径和文件名。

以下是一个完整的Apache NiFi流程示例：

1. 创建一个ExecuteSQL流程处理器，命名为"Execute SQL Query"。
2. 配置"Execute SQL Query"的属性：
   • 设置数据库连接池服务。
   • 输入查询语句，例如：SELECT * FROM table_name。
   • 如果需要，配置查询参数。
3. 创建一个ConvertRecord流程处理器，命名为"Convert Record to JSON"。
4. 配置"Convert Record to JSON"的属性：
   • 设置输入记录读取器为AvroReader。
   • 设置输出记录写入器为JsonRecordSetWriter。
   • 配置记录转换策略，将SQL行转换为JSON。
5. 创建一个PutFile流程处理器，命名为"Write JSON to File"。
6. 配置"Write JSON to File"的属性：
   • 设置目标文件路径和文件名。

将这些流程处理器连接在一起，将"Execute SQL Query"的输出连接到"Convert Record to JSON"的输入，将"Convert Record to JSON"的输出连接到"Write JSON to File"的输入。

运行数据流，将会执行SQL查询，并将查询结果转换为JSON格式，并写入文件。

注意：上述示例仅供参考，具体的配置和代码可能需要根据实际需求进行调整。