干净虚拟机(centos 6.4)上从头到尾安装并调试Mdrill(四)

原创
2014/03/18 09:49
阅读数 1.7K

13Jdbc测试

替换191.168.3.149为实际IP

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.List;

import com.alimama.mdrill.jdbc.MdrillQueryResultSet;

 

public class JDBCCall {

   public static void main(String[] args) throws   ClassNotFoundException,

         SQLException {

      // TODO Auto-generated method stub

      String connstr = "jdbc:mdrill://191.168.3.149:1107";

      Class.forName("com.alimama.mdrill.jdbc.MdrillDriver");

      Connection con = DriverManager.getConnection(connstr,   "", "");

      Statement stmt = con.createStatement();

      long mil1 = System.currentTimeMillis();

      MdrillQueryResultSet res = null;

      res = (MdrillQueryResultSet) stmt

            .executeQuery("select sum(c2) from st where thedate = '20140101'   limit 0,20");

      System.out.println("totalRecords:" + res.getTotal());

      List<String> colsNames =   res.getColumnNames();

      for (int i = 0; i < colsNames.size(); i++) {

         System.out.print(colsNames.get(i));

         System.out.print("\t");

      }

      System.out.println();

      while (res.next()) {

         for (int i = 0; i < colsNames.size();   i++) {

            System.out.print(res.getString(colsNames.get(i)));

            System.out.print("\t");

         }

      }

      con.close();

      long mil2 = System.currentTimeMillis();

      System.out.println(mil2 - mil1);

   }

}

 

运行以上程序需要的jar包列表,在jdk1.6下运行:

httpclient-4.1.1.jar, httpcore-4.1.jar,      guava-r09-jarjar.jar, hadoop-core-0.20.2-cdh3u3.jar,

commons-logging-1.1.1.jar,adhoc-core-0.18-beta.jar,adhoc-public-0.18-beta.jar,adhoc-jdbc-0.18-beta.jar

/home/mdrill/alimama/adhoc-core/lib /home/mdrill/hadoop-0.20.2-cdh3u3/home/mdrill/hadoop-0.20.2-cdh3u3/lib下可以找到。

运行完成后的效果如下:

14、停止表

./bluewhale mdrill drop st

15、使用eclipse4编译源代码

为什么使用eclipse4?因为它预置了maven插件,方便;eclipse4可在此处下载:

http://yunpan.cn/Q4iEvTDgGbwtn

使用maven导入src文件

解压0.20.8.3.src.fixbug.zip,使用eclise import导入源代码,如下图:

选择Exsiting maven projects

选择到0.20.8.3.src.fixbug文件夹,所有工程会自动被列出:

选择,并导入,导入完成后如下:

会有很多错误,在工程上右键菜单上点击maven ->Update Project 可消除所有错误,过程比较长,请耐心等待,注意工程的jdk版本一定要是1.6,否则会出现接口未实现的编译错误!

编译并打包:
adhoc-all工程上点击右键菜单 run as –>Maven build

在打开的的对话框中的goals栏中输入:package assembly:assembly,点击run

然后等待,完成后在各个工程的target目录下可以看到编译好的jar包文件。

终于完成了!


展开阅读全文
打赏
1
3 收藏
分享
加载中
更多评论
打赏
0 评论
3 收藏
1
分享
返回顶部
顶部