Class: GeoRuby::Shp4r::ShpTransaction

Inherits:
Object
  • Object
show all
Defined in:
lib/geo_ruby/shp4r/shp.rb

Overview

An object returned from ShpFile#transaction. Buffers updates to a Shapefile

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(shp, dbf) ⇒ ShpTransaction

Returns a new instance of ShpTransaction.



343
344
345
346
347
348
 
# File 'lib/geo_ruby/shp4r/shp.rb', line 343

def initialize(shp, dbf)
  @deleted = Hash.new
  @added = Array.new
  @shp = shp
  @dbf = dbf
end

Instance Attribute Details

#rollbacked ⇒ Object (readonly)

Returns the value of attribute rollbacked.



341
342
343
 
# File 'lib/geo_ruby/shp4r/shp.rb', line 341

def rollbacked
  @rollbacked
end

Instance Method Details

#add(record) ⇒ Object

add a ShpRecord at the end

Raises:



363
364
365
366
367
 
# File 'lib/geo_ruby/shp4r/shp.rb', line 363

def add(record)
  record_type = to_shp_type(record.geometry)
  raise IncompatibleGeometryException.new("Incompatible type") unless record_type==@shp.shp_type
  @added << record
end

#commit ⇒ Object

updates the physical files



370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
 
# File 'lib/geo_ruby/shp4r/shp.rb', line 370

def commit
 @shp.close
 @shp_r = open(@shp.file_root + ".shp", "rb")
 @dbf_r = open(@shp.file_root + ".dbf", "rb")
 @shp_io = open(@shp.file_root + ".shp.tmp.shp", "wb")
 @shx_io = open(@shp.file_root + ".shx.tmp.shx", "wb")
 @dbf_io = open(@shp.file_root + ".dbf.tmp.dbf", "wb")
 index = commit_delete
 min_x,max_x,min_y,max_y,min_z,max_z,min_m,max_m = commit_add(index)
 commit_finalize(min_x,max_x,min_y,max_y,min_z,max_z,min_m,max_m)
 @shp_r.close
 @dbf_r.close
 @dbf_io.close
 @shp_io.close
 @shx_io.close
 FileUtils.move(@shp.file_root + ".shp.tmp.shp", @shp.file_root + ".shp")
 FileUtils.move(@shp.file_root + ".shx.tmp.shx", @shp.file_root + ".shx")
 FileUtils.move(@shp.file_root + ".dbf.tmp.dbf", @shp.file_root + ".dbf")

 @deleted = Hash.new
 @added = Array.new

 @shp.reload!
end

#delete(i) ⇒ Object

delete a record. Does not take into account the records added in the current transaction

Raises:



351
352
353
354
 
# File 'lib/geo_ruby/shp4r/shp.rb', line 351

def delete(i)
  raise UnexistantRecordException.new("Invalid index : #{i}") if @shp.record_count <= i
  @deleted[i] = true
end

#rollback ⇒ Object

prevents the udpate from taking place



396
397
398
399
400
 
# File 'lib/geo_ruby/shp4r/shp.rb', line 396

def rollback
  @deleted = Hash.new
  @added = Array.new
  @rollbacked = true
end

#update(i, record) ⇒ Object

Update a record. In effect just a delete followed by an add.



357
358
359
360
 
# File 'lib/geo_ruby/shp4r/shp.rb', line 357

def update(i, record)
  delete(i)
  add(record)
end