MS Access

require 'win32ole'
#dostop do accessa preko ADO
# Avtor: Nebivedu
# December 2010
# UPORABA:
#**************************************************************************************************************
#	BRANJE IZ BAZE
#		require 'accessDB'					# vključevanje definicije
#		db = AccessDb.new('./BAZA.mdb')		       # berem accessovo bazo
#		db.open						# odprem konekcijo na bazo
#		db.query("SELECT * FROM tabela';")		# berem tabelo
#		field_names = db.fields 				# izpišem polja
#		puts field_names.join(";")				# izpis podatkov - delimiter je ;
# 		for i in 0..db.data.length-1			# izpis vseh podatkov iz SQL-a
#			puts db.data[i].join(";")			#podatke iz baze združim v polja in posamezno polje izpišem kot vrstico
#		end
#		db.close						# zapremo konekcijo na bazo
#	opcijsko:
#		field_types = db.types				# preberem dolžine polj
#		puts field_types.join(";")				# izpis dolžine polj
#**************************************************************************************************************
#	INSERT V BAZO:
#		require 'accessDB'					# vključevanje definicije
#		db = AccessDb.new('./BAZA.mdb')		       # berem accessovo bazo
#		db.open						# odprem konekcijo na bazo
#		db.execute("INSERT INTO TABELA (ime1) values (ime1);")
#		db.close						# zapremo konekcijo na bazo
#**************************************************************************************************************
#	KREIRANJE TABELE V BAZI:
#		require 'accessDB'					# vključevanje definicije
#		db = AccessDb.new('./BAZA.mdb')		       # berem accessovo bazo
#		db.open						# odprem konekcijo na bazo
#		db.execute("CREATE table table(RACUN DOUBLE , DAVCNA INTEGER , NAZIV CHAR);")
#		db.close						# zapremo konekcijo na bazo
#**************************************************************************************************************
#	INSERT V BAZO:
#		require 'accessDB'					# vključevanje definicije
#		db = AccessDb.new('./BAZA.mdb')		       # berem accessovo bazo
#		db.open						# odprem konekcijo na bazo
#		db.execute("DELETE FROM TABELA WHERE X <> X1;")
#		db.close						# zapremo konekcijo na bazo
#**************************************************************************************************************

class AccessDb
	#atributi
    	attr_accessor :mdb, :connection, :data, :fields, :types
    	#inicializacija
    	def initialize(mdb=nil)
        	@mdb = mdb
        	@connection = nil
        	@data = nil
        	@fields = nil
        	@types = nil
    	end
    	#definicija open connectiona
    	def open
    		#provider
        	connection_string =  'Provider=Microsoft.Jet.OLEDB.4.0;Data Source='
        	#baza - vrsta datoteke
        	connection_string << @mdb
        	#connection
        	@connection = WIN32OLE.new('ADODB.Connection')
        	#open connection
        	@connection.Open(connection_string)
    	end
    	#query
    	def query(sql)
    		#ado zabranje
        	recordset = WIN32OLE.new('ADODB.Recordset')
        	#open connection z sql-om in ...
        	recordset.Open(sql, @connection)
        	#tipi polj
        	@types = []
        		recordset.Fields.each do |field|
            			@types << field.Type
        	end
        	#imena polj
        	@fields = []
        	#naberem imena polj
        	recordset.Fields.each do |field|
            		@fields << field.Name
        	end
        	#podatki
        	begin
        		#poberem vse podatke naenkrat(omejitev je )
            		@data = recordset.GetRows.transpose
        	rescue
        		#reševanje napak
            		@data = []
        	end
        	#close pobiranja podatkov
        	recordset.Close
    	end
    	#izvedba ukaza (insert, create, delete)
    	def execute(sql)
        	@connection.Execute(sql)
    	end
    	#close connection
    	def close
        	@connection.Close
    	end
end