Articles of jdbc

使用Node Lambda通过JDBC连接到AWS Athena时出错

我的目标 我正在尝试使用AWS的JDBC驱动程序来允许运行Node 6.10的Lambda函数连接到AWS Athena并创build一个数据库。 (我也希望能够创build和查询该数据库内的表)。 我所试过的 我已经尝试了下面的代码从一个类似的问题的答案: var JDBC = require('jdbc'); var jinst = require('jdbc/lib/jinst'); if (!jinst.isJvmCreated()) { jinst.addOption("-Xrs"); jinst.setupClasspath(['./AthenaJDBC41-*.jar']); } var config = { // Required url: 'jdbc:awsathena://athena.us-east-1.amazonaws.com:443', // Optional drivername: 'com.amazonaws.athena.jdbc.AthenaDriver', minpoolsize: 10, maxpoolsize: 100, properties: { s3_staging_dir: 's3://aws-athena-query-results-*/', log_path: '/logs/athenajdbc.log', user: 'access_key', password: 'secret_key' } }; var hsqldb = new JDBC(config); hsqldb.initialize(function(err) […]

Node.js和jdbc:TypeError:无法读取未定义的属性“url”

我是nodejs和JavaScript的新手。 我正在尝试连接MySQL到nodejs的一个非常基本的例子。 我正在使用一个npm jdbc包来达到这个目的。 下面是我用于连接和获取exception下面的代码片段。 你能帮我解决这个问题吗? 码: var express = require('express'); var app = express(); var server = require('http').Server(app); var https =require('http'); var io = require('socket.io')(server); var kafka = require('kafka-node'); var cassandra = require('cassandra-driver'); var jdbc = new (require('jdbc')); var jinst = require('jdbc/lib/jinst'); var Pool = require('jdbc/lib/pool'); var _ = require('underscore'); // var cors = […]

nodejs通过phoenix和druid连接到hbase

我已经安装了Phoenix-phoenix-4.3.1,并通过sqline成功连接到hbase两台机器都是集群的一部分,另外一台机器不属于集群,也没有hadoop组件。 只是访问zookeeper的sqlline访问是好的,但通过应用程序(npm)通过德鲁伊连接运行到一个错误 我发现npm https://github.com/gaodazhu/phoenix-client 我得到以下 May 22, 2015 2:08:25 AM com.alibaba.druid.pool.DruidDataSource error SEVERE: dataSource init error java.sql.SQLException: org.apache.phoenix.jdbc.PhoenixDriver at com.alibaba.druid.util.JdbcUtils.createDriver(JdbcUtils.java:514) at com.alibaba.druid.pool.DruidDataSource.init(DruidDataSource.java:565) at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:878) at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:874) at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:97) at com.mlsc.DBClient.query(DBClient.java:134) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) Caused by: java.lang.ClassNotFoundException: org.apache.phoenix.jdbc.PhoenixDriver at java.net.URLClassLoader$1.run(URLClassLoader.java:366) at java.net.URLClassLoader$1.run(URLClassLoader.java:355) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:354) at java.lang.ClassLoader.loadClass(ClassLoader.java:425) at […]

使用node.js通过jdbc连接到impala

我正在使用npm模块jdbc尝试连接到Cloudera Impala。 我已经尝试了hiveserver2的apache hive-jdbc-0.13.1-cdh5.3.3.jar以及Cloudera JDBC ImpalaJDBC41.jar var jdbc = new (require('jdbc')); var config = { libpath: '/home/ubuntu/downloads/impala_jdbc/hive-jdbc-0.13.1-cdh5.3.3.jar', libs:'/home/ubuntu/downloads/impala_jdbc/lib/*.jar', drivername: 'org.apache.hive.jdbc.HiveDriver', url: 'jdbc:hive2://54.172.122.6:21050/;auth=noSasl' + process.argv[2] }; //Initialize jdbc object jdbc.initialize(config, function(err, res){ if (err){ console.log(err); } }); jdbc.open(function(err, conn) { if (conn) { //Run first query jdbc.executeQuery('show databases', function(err, results){ if (err){ console.log(err); } else if […]

node.js和npm jdbc与kerberized apache phoenix的封装问题

我使用nodejs和npm jdbc软件包连接到hortonworks上的Kerberized Apache phoenix,我能够通过nodejs和jdbc软件包连接到非kerberized phoenix,但是面对kerberized phoenix的Kerberos身份validation错误。 如果有人做了类似的事情,请给点方向。 Klist命令: klist -k -t -e /etc/security/keytabs/kafka.headless.keytab Keytab name: FILE:/etc/security/keytabs/kafka.headless.keytab KVNO Timestamp Principal —- —————– ——————————————————– 1 09/30/16 10:10:27 kafka@REALM.LAN (aes256-cts-hmac-sha1-96) 码: var express = require('express'); var app = express(); var server = require('http').Server(app); var https =require('http'); var io = require('socket.io')(server); var kafka = require('kafka-node'); var cassandra = require('cassandra-driver'); […]

我可以连接nodejs teradata(任何nodejs npm为此)?

无论如何,我可以连接teradata到nodejs服务器? 我有使用情况下,我需要拉我余下的API中的Teradata信息。 我可以使用这个 npm包吗?

如何为node.js JDBC模块configurationJava堆大小?

在我的node.js应用程序中,我使用JDBC连接到Oracle数据库。 我需要增加我的Java堆空间,以防止以下错误: java.lang.OutOfMemoryError: Java heap space 我知道有一个terminal选项设置最大的Java堆大小( -Xmx<size> ),但问题是,我没有明确地运行java,它发生在我的JDBC模块(这取决于java模块 ),所以我不能使用该terminal选项。 那么如何在我的情况下configurationJava堆大小?

如何使用node-jdbc获取生成的ID?

我正在使用node-jdbc和oracle驱动程序“ojdbc6_g.jar”连接到Oracle数据库。 我想执行一些插入查询。 问题: 如何使用node-jdbc将行插入到oracle时获取生成的Id? 我试图调用statement.getGeneratedKeys()但它在callback中返回以下错误: > { [Error: Error running instance method java.sql.SQLException: > operation not allowed > at oracle.jdbc.driver.OracleStatement.getGeneratedKeys(OracleStatement.java:8425) > at oracle.jdbc.driver.OracleStatementWrapper.getGeneratedKeys(OracleStatementWrapper.java:1106) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:483) ] cause: {} }