jdbc Apache Olingo 连接器
jdbc connector for Apache Olingo
我已经使用 Apache Olingo 开发了一个 JAVA 项目,我在其中尝试从 MySQL 数据库中获取数据,但出现以下错误
遇到异常!
com.mysql.jdbc.Driver
要在 Apache olingo 中为此导入哪个库。下面是我的JavaClass
private EntityCollection getData(EdmEntitySet edmEntitySet){
EntityCollection productsCollection = new EntityCollection();
// check for which EdmEntitySet the data is requested
if(DemoEdmProvider.ES_PRODUCTS_NAME.equals(edmEntitySet.getName())) {
List<org.apache.olingo.commons.api.data.Entity> productList = productsCollection.getEntities();
try
{
// create our mysql database connection
//String myDriver = "org.gjt.mm.mysql.Driver";
String myDriver ="com.mysql.jdbc.Driver";
String myUrl = "jdbc:mysql://localhost:3306/testDB";
Class.forName(myDriver);
Connection conn = DriverManager.getConnection(myUrl, "root", "test1234");
// our SQL SELECT query.
// if you only need a few columns, specify them by name instead of using "*"
String query = "SELECT * FROM Employee";
// create the java statement
Statement st = conn.createStatement();
// execute the query, and get a java resultset
ResultSet rs = st.executeQuery(query);
// iterate through the java resultset
while (rs.next())
{
String NAME = rs.getString("NAME");
String CITY = rs.getString("CITY");
int AGE = rs.getInt("AGE");
// print the results
final Entity e1 = new Entity()
.addProperty(new Property(null, "NAME", ValueType.PRIMITIVE, NAME))
.addProperty(new Property(null, "CITY", ValueType.PRIMITIVE, CITY))
.addProperty(new Property(null, "AGE", ValueType.PRIMITIVE,
AGE));
e1.setId(createId("Products", 1));
productList.add(e1);
}
st.close();
}
catch (Exception e)
{
System.err.println("Got an exception! ");
System.err.println(e.getMessage());
}
}
您可以添加 mysql 连接器 Jar 文件
link 分别是:https://dev.mysql.com/downloads/connector/j/
下载并导入您的项目-->右键单击-->导入-->文件系统-->浏览-->你在哪里存储你的连接器
我已经使用 Apache Olingo 开发了一个 JAVA 项目,我在其中尝试从 MySQL 数据库中获取数据,但出现以下错误
遇到异常! com.mysql.jdbc.Driver
要在 Apache olingo 中为此导入哪个库。下面是我的JavaClass
private EntityCollection getData(EdmEntitySet edmEntitySet){
EntityCollection productsCollection = new EntityCollection();
// check for which EdmEntitySet the data is requested
if(DemoEdmProvider.ES_PRODUCTS_NAME.equals(edmEntitySet.getName())) {
List<org.apache.olingo.commons.api.data.Entity> productList = productsCollection.getEntities();
try
{
// create our mysql database connection
//String myDriver = "org.gjt.mm.mysql.Driver";
String myDriver ="com.mysql.jdbc.Driver";
String myUrl = "jdbc:mysql://localhost:3306/testDB";
Class.forName(myDriver);
Connection conn = DriverManager.getConnection(myUrl, "root", "test1234");
// our SQL SELECT query.
// if you only need a few columns, specify them by name instead of using "*"
String query = "SELECT * FROM Employee";
// create the java statement
Statement st = conn.createStatement();
// execute the query, and get a java resultset
ResultSet rs = st.executeQuery(query);
// iterate through the java resultset
while (rs.next())
{
String NAME = rs.getString("NAME");
String CITY = rs.getString("CITY");
int AGE = rs.getInt("AGE");
// print the results
final Entity e1 = new Entity()
.addProperty(new Property(null, "NAME", ValueType.PRIMITIVE, NAME))
.addProperty(new Property(null, "CITY", ValueType.PRIMITIVE, CITY))
.addProperty(new Property(null, "AGE", ValueType.PRIMITIVE,
AGE));
e1.setId(createId("Products", 1));
productList.add(e1);
}
st.close();
}
catch (Exception e)
{
System.err.println("Got an exception! ");
System.err.println(e.getMessage());
}
}
您可以添加 mysql 连接器 Jar 文件 link 分别是:https://dev.mysql.com/downloads/connector/j/
下载并导入您的项目-->右键单击-->导入-->文件系统-->浏览-->你在哪里存储你的连接器