Skip to content

Commit

Permalink
* 2011-07-15 - fsf
Browse files Browse the repository at this point in the history
- new: added --driver option to manually specify jdbc class to load
- new: added auto db2 driver load for jdbc:db2: URIs
  • Loading branch information
fsfiii committed Jul 16, 2011
1 parent 51b33d7 commit 0bbc43f
Show file tree
Hide file tree
Showing 3 changed files with 19 additions and 6 deletions.
4 changes: 4 additions & 0 deletions CHANGELOG
@@ -1,2 +1,6 @@
* 2011-07-15 - fsf
- new: added --driver option to manually specify jdbc class to load
- new: added auto db2 driver load for jdbc:db2: URIs

* 2011-07-02 - fsf
- initial import
17 changes: 13 additions & 4 deletions bin/nosqoop4u.rb
Expand Up @@ -13,6 +13,7 @@ def usage
-p, --pass # db password (env NS4U_PASS)
-e, --query # sql query to run
-F, --delim # delimiter (default: ^A)
-d, --driver # JDBC driver class to load
-h, --help
EOF
end
Expand All @@ -24,6 +25,7 @@ def initialize cfg
@db_url = cfg[:db_url] || ENV['NS4U_URL']
@db_host = cfg[:db_host] || ENV['NS4U_HOST']
@db_name = cfg[:db_name] || ENV['NS4U_DB']
@driver = cfg[:driver] || ENV['NS4U_DRIVER']

load_driver
connect
Expand All @@ -48,19 +50,23 @@ def hack_jdbc
end

def load_driver
eval @driver if @driver

case @db_url
when /jdbc:mysql:/
Java::com.mysql.jdbc.Driver
com.mysql.jdbc.Driver
# handle 0000-00-00 timestamps without an exception, lulz
#@db_url << '?zeroDateTimeBehavior=round' if @db_url !~
@db_url << '?zeroDateTimeBehavior=convertToNull' if @db_url !~
/zeroDateTimeBehavior/
when /jdbc:oracle:/
Java::oracle.jdbc.OracleDriver
oracle.jdbc.OracleDriver
when /jdbc:postgresql:/
Java::org.postgresql.Driver
org.postgresql.Driver
when /jdbc:db2:/
com.ibm.db2.jcc.DB2Driver
else
raise "error: unknown database type"
raise "error: unknown database type" if not @driver
end
end

Expand Down Expand Up @@ -179,6 +185,7 @@ def o.puts s
[ '--pass', '-p', GetoptLong::REQUIRED_ARGUMENT ],
[ '--query', '-e', GetoptLong::REQUIRED_ARGUMENT ],
[ '--delim', '-F', GetoptLong::REQUIRED_ARGUMENT ],
[ '--driver', '-d', GetoptLong::REQUIRED_ARGUMENT ],
[ '--help', '-h', GetoptLong::NO_ARGUMENT ]
)

Expand All @@ -194,6 +201,8 @@ def o.puts s
opts[:db_pass] = arg
when '--delim'
opts[:delim] = arg
when '--driver'
opts[:driver] = arg
when '--query'
sql = arg
when '--help'
Expand Down
4 changes: 2 additions & 2 deletions nosqoop4u.gemspec
Expand Up @@ -2,8 +2,8 @@ Gem::Specification.new do |s|
s.name = 'nosqoop4u'
s.rubyforge_project = 'nosqoop4u'
s.platform = 'java'
s.version = '0.0.1'
s.date = '2011-07-02'
s.version = '0.1.0'
s.date = '2011-07-15'
s.authors = ["Frank Fejes"]
s.email = 'frank@fejes.net'
s.summary =
Expand Down

0 comments on commit 0bbc43f

Please sign in to comment.