接上篇《构建一个完整的数据仓库(七)doris入门之crud操作》,我们介绍了使用navicat来操作doris,但是最终我们还是要通过程序来进行处理,因此这里我们来写一个jdbc查询doris里面的user表数据。不多说,直接上代码。
import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; public class Test { public static void main(String[] args) { // 加载驱动程序 try { Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace(); } // 创建数据库连接 java.sql.Connection conn = null; try { String url = "jdbc:mysql://192.168.31.30:39030/test1"; String user = "root"; String password = ""; conn = DriverManager.getConnection(url, user, password); } catch (SQLException e) { e.printStackTrace(); } // 发起查询,取结果 java.sql.Statement stmt = null; ResultSet rs = null; try { stmt = conn.createStatement(); rs = stmt.executeQuery("select * from user"); while (rs.next()) { System.out.print(rs.getInt("userid") + " "); System.out.print(rs.getInt("username") + " "); System.out.print(rs.getInt("usersex") + " "); System.out.println(rs.getString("userage") + " "); } } catch (SQLException e) { e.printStackTrace(); } // 关闭数据库连接 try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }
上面就是一个完整的使用jdbc查询doris里面我们刚才创建的user表的数据的demo。端口的话我们这里是39030,是由于我们之前安装的时候服务器有其他服务运行,导致端口冲突,因此这里在实际使用的过程中,改为自己环境的端口即可。
额外说下:本例子主要是给大家演示一下,而且使用直接这么简单的使用jdbc连接doris在生产环境中是不允许的,生产环境中需要配置连接池等等。所以在使用的时候一定要注意。
还没有评论,来说两句吧...