weka(0)--weka 连接数据库 java实现代码

//  在java 中调用weka连接数据库.记得要修复weka.jar包中weka/experiment/DatabaseUtils.props中的数据转换

 
package com.weka.comm;

import weka.core.Instances;

import weka.experiment.InstanceQuery;

/**

 * weka 连接数据库的工具类

 *

 * @author Administrator

 *

 */

public class DbUtils {

 /**

  * 得到数据实例查询器

  *

  * @param url

  * @param user

  * @param pwd

  * @return

  */

 public InstanceQuery getQuery(String url, String user, String pwd) {

  InstanceQuery query = null;

  try {

   query = new InstanceQuery();

   query.setDatabaseURL(url);

   query.setUsername(user);

   query.setPassword(pwd);

  } catch (Exception e) {

   // TODO Auto-generated catch block

   e.printStackTrace();

  }

  return query;

 }

 /**

  * 查询器根据sql查找

  *

  * @param query

  * @param sql

  * @return

  */

 public Instances getData(InstanceQuery query, String sql) {

  Instances data = null;

  query.setQuery(sql);

  try {

   // 将查询的数据反转成数据实例的样式

   data = query.retrieveInstances();

  } catch (Exception e) {

   e.printStackTrace();

  }

  return data;

 }

}