Tag: 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: {} }
