RubyGems - jruby-pg - Versions diffs - 0.1-java - Mend

jruby-pg 0.1-java

This diff represents the content of publicly available package versions that have been released to one of the supported registries. The information contained in this diff is provided for informational purposes only and reflects changes between package versions as they appear in their respective public registries.

Files changed (51) hide show

checksums.yaml +7 -0
data/.gemtest +0 -0
data/BSDL +22 -0
data/ChangeLog +0 -0
data/Contributors.rdoc +45 -0
data/History.rdoc +270 -0
data/LICENSE +56 -0
data/Manifest.txt +44 -0
data/POSTGRES +23 -0
data/README-OS_X.rdoc +68 -0
data/README-Windows.rdoc +67 -0
data/README.ja.rdoc +14 -0
data/README.rdoc +102 -0
data/Rakefile +211 -0
data/Rakefile.cross +273 -0
data/ext/gvl_wrappers.c +13 -0
data/ext/pg.c +545 -0
data/ext/pg_connection.c +3643 -0
data/ext/pg_errors.c +89 -0
data/ext/pg_result.c +920 -0
data/lib/pg.rb +52 -0
data/lib/pg/connection.rb +179 -0
data/lib/pg/constants.rb +11 -0
data/lib/pg/exceptions.rb +11 -0
data/lib/pg/result.rb +16 -0
data/lib/pg_ext.jar +0 -0
data/sample/array_insert.rb +20 -0
data/sample/async_api.rb +106 -0
data/sample/async_copyto.rb +39 -0
data/sample/async_mixed.rb +56 -0
data/sample/check_conn.rb +21 -0
data/sample/copyfrom.rb +81 -0
data/sample/copyto.rb +19 -0
data/sample/cursor.rb +21 -0
data/sample/disk_usage_report.rb +186 -0
data/sample/issue-119.rb +94 -0
data/sample/losample.rb +69 -0
data/sample/minimal-testcase.rb +17 -0
data/sample/notify_wait.rb +72 -0
data/sample/pg_statistics.rb +294 -0
data/sample/replication_monitor.rb +231 -0
data/sample/test_binary_values.rb +33 -0
data/sample/wal_shipper.rb +434 -0
data/sample/warehouse_partitions.rb +320 -0
data/spec/data/expected_trace.out +26 -0
data/spec/data/random_binary_data +0 -0
data/spec/lib/helpers.rb +350 -0
data/spec/pg/connection_spec.rb +1276 -0
data/spec/pg/result_spec.rb +345 -0
data/spec/pg_spec.rb +44 -0
metadata +190 -0

data/spec/pg/result_spec.rb ADDED

@@ -0,0 +1,345 @@
+#!/usr/bin/env rspec
+# encoding: utf-8
+BEGIN {
+	require 'pathname'
+	basedir = Pathname( __FILE__ ).dirname.parent.parent
+	libdir = basedir + 'lib'
+	$LOAD_PATH.unshift( basedir.to_s ) unless $LOAD_PATH.include?( basedir.to_s )
+	$LOAD_PATH.unshift( libdir.to_s ) unless $LOAD_PATH.include?( libdir.to_s )
+}
+require 'rspec'
+require 'spec/lib/helpers'
+require 'pg'
+describe PG::Result do
+	before( :all ) do
+		@conn = setup_testing_db( "PG_Result" )
+	end
+	before( :each ) do
+		@conn.exec( 'BEGIN' )
+	end
+	after( :each ) do
+		@conn.exec( 'ROLLBACK' )
+	end
+	after( :all ) do
+		teardown_testing_db( @conn )
+	end
+	#
+	# Examples
+	#
+	it "should act as an array of hashes" do
+		res = @conn.exec("SELECT 1 AS a, 2 AS b")
+		res[0]['a'].should== '1'
+		res[0]['b'].should== '2'
+	end
+	it "should yield a row as an array" do
+		res = @conn.exec("SELECT 1 AS a, 2 AS b")
+		list = []
+		res.each_row { |r| list << r }
+		list.should eq [['1', '2']]
+	end
+	it "should insert nil AS NULL and return NULL as nil" do
+		res = @conn.exec("SELECT $1::int AS n", [nil])
+		res[0]['n'].should be_nil()
+	end
+	it "encapsulates errors in a PGError object" do
+		exception = nil
+		begin
+			@conn.exec( "SELECT * FROM nonexistant_table" )
+		rescue PGError => err
+			exception = err
+		end
+		result = exception.result
+		result.should be_a( described_class() )
+		result.error_field( PG::PG_DIAG_SEVERITY ).should == 'ERROR'
+		result.error_field( PG::PG_DIAG_SQLSTATE ).should == '42P01'
+		result.error_field( PG::PG_DIAG_MESSAGE_PRIMARY ).
+			should == 'relation "nonexistant_table" does not exist'
+		result.error_field( PG::PG_DIAG_MESSAGE_DETAIL ).should be_nil()
+		result.error_field( PG::PG_DIAG_MESSAGE_HINT ).should be_nil()
+		result.error_field( PG::PG_DIAG_STATEMENT_POSITION ).should == '15'
+		result.error_field( PG::PG_DIAG_INTERNAL_POSITION ).should be_nil()
+		result.error_field( PG::PG_DIAG_INTERNAL_QUERY ).should be_nil()
+		result.error_field( PG::PG_DIAG_CONTEXT ).should be_nil()
+		result.error_field( PG::PG_DIAG_SOURCE_FILE ).should =~ /parse_relation\.c$|namespace\.c$/
+		result.error_field( PG::PG_DIAG_SOURCE_LINE ).should =~ /^\d+$/
+		result.error_field( PG::PG_DIAG_SOURCE_FUNCTION ).should =~ /^parserOpenTable$|^RangeVarGetRelid$/
+	end
+	it "encapsulates database object names for integrity constraint violations", :postgresql_93 do
+		@conn.exec( "CREATE TABLE integrity (id SERIAL PRIMARY KEY)" )
+		exception = nil
+		begin
+			@conn.exec( "INSERT INTO integrity VALUES (NULL)" )
+		rescue PGError => err
+			exception = err
+		end
+		result = exception.result
+		result.error_field( PG::PG_DIAG_SCHEMA_NAME ).should == 'public'
+		result.error_field( PG::PG_DIAG_TABLE_NAME ).should == 'integrity'
+		result.error_field( PG::PG_DIAG_COLUMN_NAME ).should == 'id'
+		result.error_field( PG::PG_DIAG_DATATYPE_NAME ).should be_nil
+		result.error_field( PG::PG_DIAG_CONSTRAINT_NAME ).should be_nil
+	end
+	it "should detect division by zero as SQLSTATE 22012" do
+		sqlstate = nil
+		begin
+			res = @conn.exec("SELECT 1/0")
+		rescue PGError => e
+			sqlstate = e.result.result_error_field( PG::PG_DIAG_SQLSTATE ).to_i
+		end
+		sqlstate.should == 22012
+	end
+	it "should return the same bytes in binary format that are sent in binary format" do
+		binary_file = File.join(Dir.pwd, 'spec/data', 'random_binary_data')
+		bytes = File.open(binary_file, 'rb').read
+		res = @conn.exec('VALUES ($1::bytea)',
+			[ { :value => bytes, :format => 1 } ], 1)
+		res[0]['column1'].should== bytes
+		res.getvalue(0,0).should == bytes
+		res.values[0][0].should == bytes
+		res.column_values(0)[0].should == bytes
+	end
+	it "should return the same bytes in binary format that are sent as inline text" do
+		binary_file = File.join(Dir.pwd, 'spec/data', 'random_binary_data')
+		bytes = File.open(binary_file, 'rb').read
+		@conn.exec("SET standard_conforming_strings=on")
+		res = @conn.exec("VALUES ('#{PG::Connection.escape_bytea(bytes)}'::bytea)", [], 1)
+		res[0]['column1'].should == bytes
+		res.getvalue(0,0).should == bytes
+		res.values[0][0].should == bytes
+		res.column_values(0)[0].should == bytes
+	end
+	it "should return the same bytes in text format that are sent in binary format" do
+		binary_file = File.join(Dir.pwd, 'spec/data', 'random_binary_data')
+		bytes = File.open(binary_file, 'rb').read
+		res = @conn.exec('VALUES ($1::bytea)',
+			[ { :value => bytes, :format => 1 } ])
+		PG::Connection.unescape_bytea(res[0]['column1']).should== bytes
+	end
+	it "should return the same bytes in text format that are sent as inline text" do
+		binary_file = File.join(Dir.pwd, 'spec/data', 'random_binary_data')
+		in_bytes = File.open(binary_file, 'rb').read
+		out_bytes = nil
+		@conn.exec("SET standard_conforming_strings=on")
+		res = @conn.exec("VALUES ('#{PG::Connection.escape_bytea(in_bytes)}'::bytea)", [], 0)
+		out_bytes = PG::Connection.unescape_bytea(res[0]['column1'])
+		out_bytes.should == in_bytes
+	end
+	it "should return the parameter type of the specified prepared statement parameter", :postgresql_92 do
+		query = 'SELECT * FROM pg_stat_activity WHERE user = $1::name AND query = $2::text'
+		@conn.prepare( 'queryfinder', query )
+		res = @conn.describe_prepared( 'queryfinder' )
+		@conn.exec( 'SELECT format_type($1, -1)', [res.paramtype(0)] ).getvalue( 0, 0 ).
+			should == 'name'
+		@conn.exec( 'SELECT format_type($1, -1)', [res.paramtype(1)] ).getvalue( 0, 0 ).
+			should == 'text'
+	end
+	it "should raise an exception when a negative index is given to #fformat" do
+		res = @conn.exec('SELECT * FROM pg_stat_activity')
+		expect {
+			res.fformat( -1 )
+		}.to raise_error( ArgumentError, /column number/i )
+	end
+	it "should raise an exception when a negative index is given to #fmod" do
+		res = @conn.exec('SELECT * FROM pg_stat_activity')
+		expect {
+			res.fmod( -1 )
+		}.to raise_error( ArgumentError, /column number/i )
+	end
+	it "should raise an exception when a negative index is given to #[]" do
+		res = @conn.exec('SELECT * FROM pg_stat_activity')
+		expect {
+			res[ -1 ]
+		}.to raise_error( IndexError, /-1 is out of range/i )
+	end
+	it "should raise allow for conversion to an array of arrays" do
+		@conn.exec( 'CREATE TABLE valuestest ( foo varchar(33) )' )
+		@conn.exec( 'INSERT INTO valuestest ("foo") values (\'bar\')' )
+		@conn.exec( 'INSERT INTO valuestest ("foo") values (\'bar2\')' )
+		res = @conn.exec( 'SELECT * FROM valuestest' )
+		res.values.should == [ ["bar"], ["bar2"] ]
+	end
+	# PQfmod
+	it "can return the type modifier for a result column" do
+		@conn.exec( 'CREATE TABLE fmodtest ( foo varchar(33) )' )
+		res = @conn.exec( 'SELECT * FROM fmodtest' )
+		res.fmod( 0 ).should == 33 + 4 # Column length + varlena size (4)
+	end
+	it "should raise an exception when an invalid index is passed to PG::Result#fmod" do
+		@conn.exec( 'CREATE TABLE fmodtest ( foo varchar(33) )' )
+		res = @conn.exec( 'SELECT * FROM fmodtest' )
+		expect { res.fmod(1) }.to raise_error( ArgumentError )
+	end
+	it "should raise an exception when an invalid (negative) index is passed to PG::Result#fmod" do
+		@conn.exec( 'CREATE TABLE fmodtest ( foo varchar(33) )' )
+		res = @conn.exec( 'SELECT * FROM fmodtest' )
+		expect { res.fmod(-11) }.to raise_error( ArgumentError )
+	end
+	it "shouldn't raise an exception when a valid index is passed to PG::Result#fmod for a column with no typemod" do
+		@conn.exec( 'CREATE TABLE fmodtest ( foo text )' )
+		res = @conn.exec( 'SELECT * FROM fmodtest' )
+		res.fmod( 0 ).should == -1 # and it shouldn't raise an exception, either
+	end
+	# PQftable
+	it "can return the oid of the table from which a result column was fetched" do
+		@conn.exec( 'CREATE TABLE ftabletest ( foo text )' )
+		res = @conn.exec( 'SELECT * FROM ftabletest' )
+		res.ftable( 0 ).should == be_nonzero()
+	end
+	it "should raise an exception when an invalid index is passed to PG::Result#ftable" do
+		@conn.exec( 'CREATE TABLE ftabletest ( foo text )' )
+		res = @conn.exec( 'SELECT * FROM ftabletest' )
+		expect { res.ftable(18) }.to raise_error( ArgumentError )
+	end
+	it "should raise an exception when an invalid (negative) index is passed to PG::Result#ftable" do
+		@conn.exec( 'CREATE TABLE ftabletest ( foo text )' )
+		res = @conn.exec( 'SELECT * FROM ftabletest' )
+		expect { res.ftable(-2) }.to raise_error( ArgumentError )
+	end
+	it "shouldn't raise an exception when a valid index is passed to PG::Result#ftable for a " +
+	   "column with no corresponding table" do
+		@conn.exec( 'CREATE TABLE ftabletest ( foo text )' )
+		res = @conn.exec( 'SELECT foo, LENGTH(foo) as length FROM ftabletest' )
+		res.ftable( 1 ).should == PG::INVALID_OID # and it shouldn't raise an exception, either
+	end
+	# PQftablecol
+	it "can return the column number (within its table) of a column in a result" do
+		@conn.exec( 'CREATE TABLE ftablecoltest ( foo text, bar numeric )' )
+		res = @conn.exec( 'SELECT * FROM ftablecoltest' )
+		res.ftablecol( 0 ).should == 1
+		res.ftablecol( 1 ).should == 2
+	end
+	it "should raise an exception when an invalid index is passed to PG::Result#ftablecol" do
+		@conn.exec( 'CREATE TABLE ftablecoltest ( foo text, bar numeric )' )
+		res = @conn.exec( 'SELECT * FROM ftablecoltest' )
+		expect { res.ftablecol(32) }.to raise_error( ArgumentError )
+	end
+	it "should raise an exception when an invalid (negative) index is passed to PG::Result#ftablecol" do
+		@conn.exec( 'CREATE TABLE ftablecoltest ( foo text, bar numeric )' )
+		res = @conn.exec( 'SELECT * FROM ftablecoltest' )
+		expect { res.ftablecol(-1) }.to raise_error( ArgumentError )
+	end
+	it "shouldn't raise an exception when a valid index is passed to PG::Result#ftablecol for a " +
+	   "column with no corresponding table" do
+		@conn.exec( 'CREATE TABLE ftablecoltest ( foo text )' )
+		res = @conn.exec( 'SELECT foo, LENGTH(foo) as length FROM ftablecoltest' )
+		res.ftablecol(1).should == 0 # and it shouldn't raise an exception, either
+	end
+	it "can be manually checked for failed result status (async API)" do
+		@conn.send_query( "SELECT * FROM nonexistant_table" )
+		res = @conn.get_result
+		expect {
+			res.check
+		}.to raise_error( PG::Error, /relation "nonexistant_table" does not exist/ )
+	end
+	it "can return the values of a single field" do
+		res = @conn.exec( "SELECT 1 AS x, 'a' AS y UNION ALL SELECT 2, 'b'" )
+		res.field_values( 'x' ).should == ['1', '2']
+		res.field_values( 'y' ).should == ['a', 'b']
+		expect{ res.field_values( '' ) }.to raise_error(IndexError)
+		expect{ res.field_values( :x ) }.to raise_error(TypeError)
+	end
+	it "should raise a proper exception for a nonexistant table" do
+		expect {
+			@conn.exec( "SELECT * FROM nonexistant_table" )
+		}.to raise_error( PG::UndefinedTable, /relation "nonexistant_table" does not exist/ )
+	end
+	it "should raise a more generic exception for an unknown SQLSTATE" do
+		old_error = PG::ERROR_CLASSES.delete('42P01')
+		begin
+			expect {
+				@conn.exec( "SELECT * FROM nonexistant_table" )
+			}.to raise_error{|error|
+				error.should be_an_instance_of(PG::SyntaxErrorOrAccessRuleViolation)
+				error.to_s.should match(/relation "nonexistant_table" does not exist/)
+			}
+		ensure
+			PG::ERROR_CLASSES['42P01'] = old_error
+		end
+	end
+	it "should raise a ServerError for an unknown SQLSTATE class" do
+		old_error1 = PG::ERROR_CLASSES.delete('42P01')
+		old_error2 = PG::ERROR_CLASSES.delete('42')
+		begin
+			expect {
+				@conn.exec( "SELECT * FROM nonexistant_table" )
+			}.to raise_error{|error|
+				error.should be_an_instance_of(PG::ServerError)
+				error.to_s.should match(/relation "nonexistant_table" does not exist/)
+			}
+		ensure
+			PG::ERROR_CLASSES['42P01'] = old_error1
+			PG::ERROR_CLASSES['42'] = old_error2
+		end
+	end
+	it "should raise a proper exception for a nonexistant schema" do
+		expect {
+			@conn.exec( "DROP SCHEMA nonexistant_schema" )
+		}.to raise_error( PG::InvalidSchemaName, /schema "nonexistant_schema" does not exist/ )
+	end
+	it "the raised result should be nil in case of a connection error" do
+		c = PGconn.connect_start( '127.0.0.1', 54320, "", "", "me", "xxxx", "somedb" )
+		expect {
+			c.exec "select 1"
+		}.to raise_error{|error|
+			error.should be_an_instance_of(PG::UnableToSend)
+			error.result.should == nil
+		}
+	end
+end

data/spec/pg_spec.rb ADDED

@@ -0,0 +1,44 @@
+#!/usr/bin/env rspec
+# encoding: utf-8
+BEGIN {
+	require 'pathname'
+	basedir = Pathname( __FILE__ ).dirname.parent
+	libdir = basedir + 'lib'
+	$LOAD_PATH.unshift( basedir.to_s ) unless $LOAD_PATH.include?( basedir.to_s )
+	$LOAD_PATH.unshift( libdir.to_s ) unless $LOAD_PATH.include?( libdir.to_s )
+}
+require 'rspec'
+require 'spec/lib/helpers'
+require 'pg'
+describe PG do
+	it "knows what version of the libpq library is loaded", :postgresql_91 do
+		PG.library_version.should be_an( Integer )
+		PG.library_version.should >= 90100
+	end
+	it "knows whether or not the library is threadsafe" do
+		PG.should be_threadsafe()
+	end
+	it "does have hierarchical error classes" do
+		PG::UndefinedTable.ancestors[0,4].should == [
+				PG::UndefinedTable,
+				PG::SyntaxErrorOrAccessRuleViolation,
+				PG::ServerError,
+				PG::Error]
+		PG::InvalidSchemaName.ancestors[0,3].should == [
+				PG::InvalidSchemaName,
+				PG::ServerError,
+				PG::Error]
+	end
+end

metadata ADDED

@@ -0,0 +1,190 @@
+--- !ruby/object:Gem::Specification
+name: jruby-pg
+version: !ruby/object:Gem::Version
+  version: '0.1'
+platform: java
+authors:
+- Charles Nutter
+- John Shahid
+autorequire:
+bindir: bin
+cert_chain: []
+date: 2017-05-09 00:00:00.000000000 Z
+dependencies:
+- !ruby/object:Gem::Dependency
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: '0.9'
+  name: rake-compiler
+  prerelease: false
+  type: :development
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: '0.9'
+- !ruby/object:Gem::Dependency
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: 3.5.1
+  name: hoe
+  prerelease: false
+  type: :development
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: 3.5.1
+- !ruby/object:Gem::Dependency
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: '0.2'
+  name: hoe-deveiate
+  prerelease: false
+  type: :development
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: '0.2'
+- !ruby/object:Gem::Dependency
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: '1.0'
+  name: hoe-bundler
+  prerelease: false
+  type: :development
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: '1.0'
+- !ruby/object:Gem::Dependency
+  requirement: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: '4.0'
+  name: rdoc
+  prerelease: false
+  type: :development
+  version_requirements: !ruby/object:Gem::Requirement
+    requirements:
+    - - "~>"
+      - !ruby/object:Gem::Version
+        version: '4.0'
+description: |-
+  This file needs a translation of the English README. Pull requests, patches, or
+  volunteers gladly accepted.
+  Until such time, please accept my sincere apologies for not knowing Japanese.
+email:
+- headius@headius.com
+- jvshahid@gmail.com
+executables: []
+extensions: []
+extra_rdoc_files:
+- Contributors.rdoc
+- History.rdoc
+- Manifest.txt
+- README-OS_X.rdoc
+- README-Windows.rdoc
+- README.ja.rdoc
+- README.rdoc
+- POSTGRES
+- LICENSE
+- ext/gvl_wrappers.c
+- ext/pg.c
+- ext/pg_connection.c
+- ext/pg_errors.c
+- ext/pg_result.c
+files:
+- ".gemtest"
+- BSDL
+- ChangeLog
+- Contributors.rdoc
+- History.rdoc
+- LICENSE
+- Manifest.txt
+- POSTGRES
+- README-OS_X.rdoc
+- README-Windows.rdoc
+- README.ja.rdoc
+- README.rdoc
+- Rakefile
+- Rakefile.cross
+- ext/gvl_wrappers.c
+- ext/pg.c
+- ext/pg_connection.c
+- ext/pg_errors.c
+- ext/pg_result.c
+- lib/pg.rb
+- lib/pg/connection.rb
+- lib/pg/constants.rb
+- lib/pg/exceptions.rb
+- lib/pg/result.rb
+- lib/pg_ext.jar
+- sample/array_insert.rb
+- sample/async_api.rb
+- sample/async_copyto.rb
+- sample/async_mixed.rb
+- sample/check_conn.rb
+- sample/copyfrom.rb
+- sample/copyto.rb
+- sample/cursor.rb
+- sample/disk_usage_report.rb
+- sample/issue-119.rb
+- sample/losample.rb
+- sample/minimal-testcase.rb
+- sample/notify_wait.rb
+- sample/pg_statistics.rb
+- sample/replication_monitor.rb
+- sample/test_binary_values.rb
+- sample/wal_shipper.rb
+- sample/warehouse_partitions.rb
+- spec/data/expected_trace.out
+- spec/data/random_binary_data
+- spec/lib/helpers.rb
+- spec/pg/connection_spec.rb
+- spec/pg/result_spec.rb
+- spec/pg_spec.rb
+homepage: https://bitbucket.org/ged/ruby-pg
+licenses:
+- BSD-2-Clause
+- Ruby
+metadata: {}
+post_install_message:
+rdoc_options:
+- "-f"
+- fivefish
+- "-t"
+- 'pg: The Ruby Interface to PostgreSQL'
+- "-m"
+- README.rdoc
+require_paths:
+- lib
+required_ruby_version: !ruby/object:Gem::Requirement
+  requirements:
+  - - ">="
+    - !ruby/object:Gem::Version
+      version: 1.8.7
+required_rubygems_version: !ruby/object:Gem::Requirement
+  requirements:
+  - - ">="
+    - !ruby/object:Gem::Version
+      version: '0'
+requirements: []
+rubyforge_project:
+rubygems_version: 2.6.11
+signing_key:
+specification_version: 4
+summary: This file needs a translation of the English README
+test_files: []