1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
$TESTING=true
JRUBY = RUBY_PLATFORM =~ /java/
require 'rspec'
require 'date'
require 'ostruct'
require 'fileutils'
require 'win32console' if RUBY_PLATFORM =~ /mingw|mswin/
#driver_lib = File.expand_path('../../lib', __FILE__)
#$LOAD_PATH.unshift(driver_lib) unless $LOAD_PATH.include?(driver_lib)
# Prepend data_objects/do_jdbc in the repository to the load path.
# DO NOT USE installed gems, except when running the specs from gem.
#repo_root = File.expand_path('../../..', __FILE__)
#(['data_objects'] << ('do_jdbc' if JRUBY)).compact.each do |lib|
# lib_path = "#{repo_root}/#{lib}/lib"
# $LOAD_PATH.unshift(lib_path) if File.directory?(lib_path) && !$LOAD_PATH.include?(lib_path)
#end
require 'data_objects'
require 'data_objects/spec/setup'
require 'data_objects/spec/lib/pending_helpers'
require 'do_postgres'
DataObjects::Postgres.logger = DataObjects::Logger.new(STDOUT, :off)
at_exit { DataObjects.logger.flush }
CONFIG = OpenStruct.new
CONFIG.scheme = 'postgres'
CONFIG.user = ENV['DO_POSTGRES_USER'] || 'postgres'
CONFIG.pass = ENV['DO_POSTGRES_PASS'] || ''
CONFIG.user_info = unless CONFIG.pass.empty?
"#{CONFIG.user}:#{CONFIG.pass}@"
else
"#{CONFIG.user}@"
end
CONFIG.host = ENV['DO_POSTGRES_HOST'] || 'localhost'
CONFIG.port = ENV['DO_POSTGRES_PORT'] || '5432'
CONFIG.database = ENV['DO_POSTGRES_DATABASE'] || '/do_test'
CONFIG.driver = 'postgres'
CONFIG.jdbc_driver = DataObjects::Postgres.const_get('JDBC_DRIVER') rescue nil
CONFIG.uri = ENV["DO_POSTGRES_SPEC_URI"] ||"#{CONFIG.scheme}://#{CONFIG.user_info}#{CONFIG.host}:#{CONFIG.port}#{CONFIG.database}"
CONFIG.jdbc_uri = CONFIG.uri.sub(/postgres/,"jdbc:postgresql")
CONFIG.sleep = "SELECT pg_sleep(1)"
module DataObjectsSpecHelpers
def setup_test_environment
conn = DataObjects::Connection.new(CONFIG.uri)
conn.create_command(<<-EOF).execute_non_query
DROP TABLE IF EXISTS "invoices"
EOF
conn.create_command(<<-EOF).execute_non_query
DROP TABLE IF EXISTS "users"
EOF
conn.create_command(<<-EOF).execute_non_query
DROP TABLE IF EXISTS "widgets"
EOF
conn.create_command(<<-EOF).execute_non_query
CREATE TABLE "users" (
"id" SERIAL,
"name" VARCHAR(200) default 'Billy' NULL,
"fired_at" timestamp,
PRIMARY KEY ("id")
);
EOF
conn.create_command(<<-EOF).execute_non_query
CREATE TABLE "invoices" (
"invoice_number" varchar(50) NOT NULL,
PRIMARY KEY ("invoice_number")
);
EOF
conn.create_command(<<-EOF).execute_non_query
CREATE TABLE "widgets" (
"id" SERIAL,
"code" char(8) default 'A14' NULL,
"name" varchar(200) default 'Super Widget' NULL,
"shelf_location" text NULL,
"description" text NULL,
"image_data" bytea NULL,
"ad_description" text NULL,
"ad_image" bytea NULL,
"whitepaper_text" text NULL,
"cad_drawing" bytea NULL,
"flags" boolean default false,
"number_in_stock" smallint default 500,
"number_sold" integer default 0,
"super_number" bigint default 9223372036854775807,
"weight" float default 1.23,
"cost1" double precision default 10.23,
"cost2" decimal(8,2) default 50.23,
"release_date" date default '2008-02-14',
"release_datetime" timestamp default '2008-02-14 00:31:12',
"release_timestamp" timestamp with time zone default '2008-02-14 00:31:31',
PRIMARY KEY ("id")
);
EOF
1.upto(16) do |n|
conn.create_command(<<-EOF).execute_non_query(::Extlib::ByteArray.new("CAD \001 \000 DRAWING"))
insert into widgets(code, name, shelf_location, description, image_data, ad_description, ad_image, whitepaper_text, cad_drawing, super_number, weight) VALUES ('W#{n.to_s.rjust(7,"0")}', 'Widget #{n}', 'A14', 'This is a description', 'IMAGE DATA', 'Buy this product now!', 'AD IMAGE DATA', 'String', ?, 1234, 13.4)
EOF
end
conn.create_command(<<-EOF).execute_non_query
update widgets set flags = true where id = 2
EOF
conn.create_command(<<-EOF).execute_non_query
update widgets set ad_description = NULL where id = 3
EOF
conn.create_command(<<-EOF).execute_non_query
update widgets set flags = NULL where id = 4
EOF
conn.create_command(<<-EOF).execute_non_query
update widgets set cost1 = NULL where id = 5
EOF
conn.create_command(<<-EOF).execute_non_query
update widgets set cost2 = NULL where id = 6
EOF
conn.create_command(<<-EOF).execute_non_query
update widgets set release_date = NULL where id = 7
EOF
conn.create_command(<<-EOF).execute_non_query
update widgets set release_datetime = NULL where id = 8
EOF
conn.create_command(<<-EOF).execute_non_query
update widgets set release_timestamp = NULL where id = 9
EOF
conn.create_command(<<-EOF).execute_non_query
update widgets set release_datetime = '2008-07-14 00:31:12' where id = 10
EOF
conn.close
end
end
RSpec.configure do |config|
config.include(DataObjectsSpecHelpers)
config.include(DataObjects::Spec::PendingHelpers)
end
|
