接上篇《构建一个完整的数据仓库(七)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在生产环境中是不允许的,生产环境中需要配置连接池等等。所以在使用的时候一定要注意。









还没有评论,来说两句吧...