草庐IT

ShardingSphere-jdbc

全部标签

java - Hive jdbc 驱动程序以非描述性消息响应

我准备了使用hivejdbc客户端调用HadoopDB的java应用程序。当我尝试做简单的查询时,比如“select*fromstudents”,它工作正常。但是一旦我添加了一些条件语句(例如,whereage>10),它就会开始响应异常,如下所示:Causedby:java.sql.SQLException:Queryreturnednon-zerocode:2,cause:FAILED:ExecutionError,returncode2fromorg.apache.hadoop.hive.ql.exec.mr.MapRedTaskatorg.apache.hadoop.hive.

hadoop - Hive JDBC 中的无效 URL

WheninHive关于通过JDBCHive连接Exceptioninthread"main"java.sql.SQLException:InvalidURL:jdbc:hive2://192.168.14.52:10000/reportatorg.apache.hadoop.hive.jdbc.HiveConnection.(HiveConnection.java:85)atorg.apache.hadoop.hive.jdbc.HiveDriver.connect(HiveDriver.java:104)atjava.sql.DriverManager.getConnection(

java - Hive jdbc.query(sql, rowmapper) 抛出 UnCatogarized 异常

我正在使用spring-jdbc模板来查询Hive-0.11.0以下代码效果很好。publicListlistStudents(){StringSQL="select*fromStudent";Liststudents=jdbcTemplateObject.query(SQL,newStudentMapper());returnstudents;}publicclassStudentMapperimplementsRowMapper{publicStudentmapRow(ResultSetrs,introwNum)throwsSQLException{Studentstudent=n

java - 使用jdbc在hive中插入map等复杂类型

我有一个java映射(Map)和一个到配置单元服务器的JDBC连接。服务器上表的架构包含一个Map类型的列。是否可以使用JDBC将javaMap插入到具有相似数据类型的hive表列?我试过:"createtabletest(keystring,valueMap)""insertintotabletestvalues('keywer',map('subkey','subvalue'))fromdummylimit1;"引用:Hiveinsertingvaluestoanarraycomplextypecolumn但插入失败:"Error:Errorwhilecompilingstatem

mysql - Spark : Exception in thread "main" java. lang.ClassNotFoundException : com. mysql.jdbc.Driver

我在spark中编写了一个简单的程序来将数据帧写入mySql中的表。程序如下:importorg.apache.spark.SparkConfimportorg.apache.spark.SparkContextimportorg.apache.spark.rdd.RDDimportorg.apache.spark.sql.SQLContextimportorg.apache.spark.sql.hive.HiveContextimportorg.apache.spark.SparkContext._importorg.apache.spark.rdd._//importorg.apa

java - 无法从 Web 应用程序通过 JDBC 连接到 HIVE

我已经使用JDBCapi连接到HIVE2,引用here,它是成功的,所以为了便于访问,我想围绕它创建一个webapp,使用JSP作为前端页面来输入服务器名称和查询。虽然所有参数都从JSP页面正确解析为servlet,但它在连接到所需的HIVE服务器时抛出错误将libthrift和hiveJARS放在WEB-INF/lib目录中,我将其放在WEB-INF/lib和类路径中。问题是因为hivejar首先出现在WEB-INF/lib中,并且因为它没有“org.apache.thrift.protocol.TProtocol.getScheme()”方法,所以我一直没有收到这样的方法错误。我提

hadoop - Hive JDBC 连接返回 "query did not generate a resultset"

我已经从git构建了hive-jdbc,并尝试执行基本的jdbc查询来获取结果集。由于某种原因,查询抛出以下异常。16/07/0122:08:12INFOUtils:Suppliedauthorities:localhost:1000016/07/0122:08:12INFOUtils:Resolvedauthority:localhost:1000016/07/0122:08:12DEBUGTSaslTransport:openingtransportorg.apache.thrift.transport.TSaslClientTransport@5536088816/07/0122

sql-server - 索引超出范围 : JDBC SqlServer exception

我正在使用Sqoop将数据从SQL服务器导入到本地HDFS。我正在使用一个简单的自由格式查询从表中提取大约10行。下面是我从终端执行的sqoop命令:sqoopimport--connect'jdbc:sqlserver://xx.xx.xx.xx;username=xx;password=xxxxx;database=DBName'--query"SELECTtop10OrderIDfromDJShopcart_OrderItemswhere\$CONDITIONS"--split-by"OrderID"--target-dir/work/gearpurchase当我从我的本地机器执

java - Dropwizard 和 hive-jdbc 之间的不兼容

我正在尝试使用Dropwizard创建一个WSREST,以获取查询的Hive结果并以XML格式呈现。每个单独的部分都可以毫无错误地完成。当我加入所有内容时,我发现Dropwizard和hive-jdbc之间不兼容。显然hive-jdbc有jersey1作为依赖项,而Dropwizard有jersey2。我不确定这是否是问题所在。我试图排除pom.xml中的依赖项,但没有解决。我试图制作一个应用程序,只是将hive-jdbc作为依赖项放在pom.xml文件中,而不使用或导入代码的任何部分,但错误仍然发生。POM.XML3.0.04.0.0testws-test1.0.0ws-testUT

java - 使用 JDBC 和 Kerberos 身份验证连接到 Hive 时出现异常

我正在尝试使用Java中的JDBC和Kerberos身份验证连接到Hive。为此,我想出了以下代码。importjava.io.IOException;importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.SQLException;importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.security.UserGroupInformation;publicclassDbManager{privatestaticConnec