Tôi muốn chuyển đổi chuỗi JSON thành câu lệnh SQL bằng cách sử dụng bộ xử lý ConvertJSONtoSQL. dụ: Chuỗi JSON - Cơ cấuApache NiFi: Chuyển đổi JSONtoSQL (Cơ sở dữ liệu Oracle)
{"cpuwait":"0.0","servernamee":"mywindows","cpusys":"5.3","cpuidle":"77.6","datee":"29-SEP-2016","timee":"00:01:33","cpucpuno":"CPU01","cpuuser":"17.1"}
Bảng trong oracle db -
CREATE TABLE cpu (
datee varchar2(15) DEFAULT NULL,
timee varchar2(10) DEFAULT NULL,
servernamee varchar2(20) DEFAULT NULL,
cpucpuno varchar2(4) DEFAULT NULL,
cpuuser varchar2(5) DEFAULT NULL,
cpusys varchar2(5) DEFAULT NULL,
cpuwait varchar2(5) DEFAULT NULL,
cpuidle varchar2(5) DEFAULT NULL
);
Cấu hình sử dụng cho các cơ sở dữ liệu MySQL: kết nối
Database url: jdbc: mysql: // localhost: 3306/testnifi
Tên trình điều khiển cơ sở dữ liệu classname: com.mysql.jdbc.Driver
Tôi đã được kết nối thành công với MySQL bằng cách sử dụng (DBCP hồ bơi kết nối) url JDBC, tên người dùng và mật khẩu. Bộ xử lý ConvertJSONtoSQL đã hoạt động thành công ở đó và tôi nhận được lệnh chèn sql hợp lệ làm đầu ra. Nhưng khi tôi đã cố gắng cùng với cơ sở dữ liệu Oracle Tôi nhận được
ERROR [Hẹn giờ theo hướng Process Chủ đề-6] oanpstandard.ConvertJSONToSQL java.sql.SQLException: Suối đã bị đóng cửa
cấu hình của tôi cho Oracle db kết nối:
Tôi đã tìm kiếm lỗi trong google nhưng tôi thấy rằng lỗi này sẽ xảy ra khi Long Datatypes được sử dụng trong các bảng cơ sở dữ liệu nhưng tôi không sử dụng chúng. Tôi đã đi qua mã nguồn của bộ xử lý ConvertJSONtoSQL (theo dõi ngăn xếp) và cố gắng thực hiện tương tự trong nhật thực nơi tôi không nhận được bất kỳ lỗi nào, tôi có thể kết nối với cơ sở dữ liệu và thực hiện truy vấn.
Vì vậy, có bất kỳ sai lầm nào trong cấu hình của tôi không?
Nifi phiên bản - 0.7.0/1.0 (tôi nhận được cùng một lỗi trong cả hai) phiên bản
java - java8
Oracle DB phiên bản - Cơ sở dữ liệu Oracle 11g Express Edition
Hoàn Stack trace :
2016-10-19 07: 10: 06.557 ERROR [Hẹn giờ theo hướng Process chủ đề-6] oanpstandard.ConvertJSONToSQL java.sql.SQLException: Suối đã được cl osed tại oracle.jdbc.driver.LongAccessor.getBytesInternal (LongAccessor.java:156) ~ [ojdbc6.jar: 11.2.0.1.0] tại oracle.jdbc.driver.LongAccessor.getBytes (LongAccessor.java:126) ~ [ojdbc6.jar: 11.2.0.1.0] tại oracle.jdbc.driver.LongAccessor.getString (LongAccessor.java:201) ~ [ojdbc6.jar: 11.2.0.1.0] tại oracle.jdbc.driver.T4CLongAccessor .getString (T4CLongAccessor.java:427) ~ [ojdbc6.jar: 11.2.0.1.0] tại oracle.jdbc.driver.OracleResultSetImpl.getString (OracleResultSetImpl.java:1251) ~ [ojdbc6.jar: 11.2.0.1.0 ] tại oracle.jdbc.driver.OracleResultSet.getString (OracleResultSet.java:494) ~ [ojdbc6.jar: 11.2.0.1.0] tại org.apache.commons.dbcp.DelegatingResultSet.GetString (DelegatingResultSet.java:263) ~ [na na] tại org.apache.nifi.processors.standard.ConvertJSONToSQL $ ColumnDescription.from (ConvertJSONToSQL.java:677) ~ [tiết kiệm tiêu chuẩn-0.7.0-vi xử lý. jar: 0.7.0] tại org.apache.nifi.processors.standard.ConvertJSONToSQL $ TableSchema.from (ConvertJSONToSQL.java:621) ~ [tiết kiệm tiêu chuẩn-xử lý-0.7.0.jar: 0.7.0] tại org.apache.nifi.processors.standard.ConvertJSONToSQL.onTrigger (ConvertJSONToSQL.java:267) ~ [tiết kiệm tiêu chuẩn-xử lý-0.7.0.jar: 0.7.0] tại org.apache.nifi.processor.AbstractProcessor. onTrigger (AbstractProcessor.java:27) [API-tiết kiệm-0.7.0.jar: 0.7.0] tại org.apache.nifi.controller.StandardProcessorNode.onTrigger (StandardProcessorNode.java:1054) [lưu-khung-core- 0.7.0.jar: 0.7.0] tại org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call (ContinuallyRunP rocessorTask.java:136) [lưu-khung-core-0.7.0.jar: 0.7.0] tại org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call (ContinuallyRunProcessorTask.java:47) [lưu-framework- lõi-0.7.0.jar: 0.7.0] tại org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent $ 1.run (TimerDrivenSchedulingAgent.java:127) [lưu-khung-core-0.7.0.jar: 0.7. 0] tại java.util.concurrent.Executors $ RunnableAdapter.call (Unknown Source) [na 1.7.0_40] tại java.util.concurrent.FutureTask.runAndReset (Unknown Source) [na 1.7.0_40] tại java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 301 (Unknown Source) [na 1.7.0_40] tại java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (Unknown Source) [na 1.7.0_40] tại Java .util.concurrent.ThreadPoolExecuto r.runWorker (Unknown Source) [na 1.7.0_40] tại java.util.concurrent.ThreadPoolExecutor $ Worker.run (Unknown Source) [na 1.7.0_40] tại java.lang.Thread.run (Unknown Source) [na 1.7.0_40
Vui lòng cung cấp công việc xử lý của bạn –