1
我正在浏览Apache Camel并希望将数据插入数据库。 我的数据库是SqlServer。 Apache的骆驼版本是2.14.1Apache Camel JDBC插入
这是我试过至今，
import javax.sql.DataSource;
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.impl.SimpleRegistry;
import org.apache.commons.dbcp.BasicDataSource;
public class file2DB {
public static void main(String[] args) throws Exception {
final String url = "jdbc:sqlserver://localhost:1433;databaseName=TestDB";
DataSource datasource = setupDataSource(url);
SimpleRegistry simpleregistry = new SimpleRegistry();
simpleregistry.put("DataSource", datasource);
CamelContext context = new DefaultCamelContext(simpleregistry);
context.addRoutes(new file2DB().new MyRouteBuilder());
context.start();
Thread.sleep(20000);
context.stop();
}
class MyRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
try {
from("direct:myTable")
.setBody(constant("INSERT INTO employee1(empId,payrollId) VALUES('1234','4567')"))
.to("jdbc:DataSource");
} catch (Exception e) {
e.printStackTrace();
}
}
}
private static DataSource setupDataSource(String url){
BasicDataSource basicDataSource = new BasicDataSource();
basicDataSource.setDriverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
basicDataSource.setUsername("sa");
basicDataSource.setPassword("*****");
basicDataSource.setUrl(url);
return basicDataSource;
}
}
我使用下面的代码检查数据源连接和我得到的结果，所以没有问题，与它的连接看来。
Connection con=null;
try {
con = basicDataSource.getConnection();
Statement st = con.createStatement();
ResultSet rs = st.executeQuery("select * from employee1");
while (rs.next()) {
System.out.println(rs.getString(2));
}
} catch (SQLException e) {
e.printStackTrace();
}
我没有收到任何错误，数据也没有插入表中。 我也试过“选择”查询也是不起作用。
我试过记录器，它给我日志中的许多错误没有类defn发现微博等，我没有使用，我认为我的错误是不相关的。
任何帮助。
应该有一些错误/服务器终端，在例外情况某些异常情况发生时， - 当某些东西没有插入或从关联的数据库中检索时。当您试图插入数据库或从数据库中检索时，您是否在服务器日志上获取任何内容 - 堆栈跟踪？ – Tiny
如果服务器端出现错误，那么我认为我试过测试数据源的基本选择查询也应该失败吧？ – Jayesh
我尝试了MySQL，同样的问题仍然存在。我似乎在骆驼api中缺少一些东西。 – Jayesh