diff --git a/scripts/ZoneMinder/lib/ZoneMinder/Object.pm b/scripts/ZoneMinder/lib/ZoneMinder/Object.pm
index 63193bccf..af4d9fd21 100644
--- a/scripts/ZoneMinder/lib/ZoneMinder/Object.pm
+++ b/scripts/ZoneMinder/lib/ZoneMinder/Object.pm
@@ -42,7 +42,12 @@ use ZoneMinder::Config qw(:all);
 use ZoneMinder::Logger qw(:all);
 use ZoneMinder::Database qw(:all);
 
-use vars qw/ $AUTOLOAD /;
+use vars qw/ $AUTOLOAD $log $dbh/;
+
+*log = \$ZoneMinder::Logger::logger;
+*dbh = \$ZoneMinder::Database::dbh;
+
+my $debug = 1;
 
 sub new {
   my ( $parent, $id, $data ) = @_;
@@ -110,7 +115,269 @@ sub AUTOLOAD {
   return $_[0]{$name};
 }
 
+sub save {
+	my ( $self, $data, $force_insert ) = @_;
 
+	my $type = ref $self;
+	if ( ! $type ) {
+		my ( $caller, undef, $line ) = caller;
+		$log->error("No type in Object::save. self:$self from  $caller:$line");
+	}
+	my $local_dbh = eval '$'.$type.'::dbh';
+	$local_dbh = $ZoneMinder::Database::dbh if ! $local_dbh;
+	$self->set( $data ? $data : {} );
+	if ( $debug or DEBUG_ALL ) {
+		if ( $data ) {
+			foreach my $k ( keys %$data ) {
+				$log->debug("Object::save after set $k => $$data{$k} $$self{$k}");
+			}
+		} else {
+			$log->debug("No data after set");
+		}
+	}
+#$debug = 0;
+
+	my $table = eval '$'.$type.'::table';
+	my $fields = eval '\%'.$type.'::fields';
+	my $debug = eval '$'.$type.'::debug';
+	#$debug = DEBUG_ALL if ! $debug;
+
+	my %sql;
+	foreach my $k ( keys %$fields ) {
+		$sql{$$fields{$k}} = $$self{$k} if defined $$fields{$k};
+	} # end foreach
+	if ( ! $force_insert ) {
+		$sql{$$fields{updated_on}} = 'NOW()' if exists $$fields{updated_on};
+	} # end if
+	my $serial = eval '$'.$type.'::serial';
+	my @identified_by = eval '@'.$type.'::identified_by';
+
+	my $ac = sql::start_transaction( $local_dbh );
+	if ( ! $serial ) {
+		my $insert = $force_insert;
+		my %serial = eval '%'.$type.'::serial';
+		if ( ! %serial ) {
+$log->debug("No serial") if $debug;
+			# No serial columns defined, which means that we will do saving by delete/insert instead of insert/update
+			if ( @identified_by ) {
+				my $where = join(' AND ', map { $$fields{$_}.'=?' } @identified_by );
+				if ( $debug ) {
+					$log->debug("DELETE FROM $table WHERE $where");
+				} # end if
+				
+				if ( ! ( ( $_ = $local_dbh->prepare("DELETE FROM $table WHERE $where") ) and $_->execute( @$self{@identified_by} ) ) ) {
+					$where =~ s/\?/\%s/g;
+					$log->error("Error deleting: DELETE FROM $table WHERE " .  sprintf($where, map { defined $_ ? $_ : 'undef' } ( @$self{@identified_by}) ).'):' . $local_dbh->errstr);
+					$local_dbh->rollback();
+					sql::end_transaction( $local_dbh, $ac );
+					return $local_dbh->errstr;
+				} elsif ( $debug ) {
+					$log->debug("SQL succesful DELETE FROM $table WHERE $where");
+				} # end if
+			} # end if
+			$insert = 1;
+		} else {
+			foreach my $id ( @identified_by ) {
+				if ( ! $serial{$id} ) {
+          my ( $caller, undef, $line ) = caller;
+					$log->error("$id nor in serial for $type from $caller:$line") if $debug;
+					next;
+				}
+				if ( ! $$self{$id} ) {
+					($$self{$id}) = ($sql{$$fields{$id}}) = $local_dbh->selectrow_array( q{SELECT nextval('} . $serial{$id} . q{')} );
+					$log->debug("SQL statement execution SELECT nextval('$serial{$id}') returned $$self{$id}") if $debug or DEBUG_ALL;
+					$insert = 1;
+				} # end if
+			} # end foreach
+		} # end if ! %serial
+
+		if ( $insert ) {
+			my @keys = keys %sql;
+			my $command = "INSERT INTO $table (" . join(',', @keys ) . ') VALUES (' . join(',', map { '?' } @sql{@keys} ) . ')';
+			if ( ! ( ( $_ = $local_dbh->prepare($command) ) and $_->execute( @sql{@keys} ) ) ) {
+				my $error = $local_dbh->errstr;
+				$command =~ s/\?/\%s/g;
+				$log->error('SQL statement execution failed: ('.sprintf($command, , map { defined $_ ? $_ : 'undef' } ( @sql{@keys}) ).'):' . $local_dbh->errstr);
+				$local_dbh->rollback();
+				sql::end_transaction( $local_dbh, $ac );
+				return $error;
+			} # end if
+			if ( $debug or DEBUG_ALL ) {
+				$command =~ s/\?/\%s/g;
+				$log->debug('SQL statement execution: ('.sprintf($command, , map { defined $_ ? $_ : 'undef' } ( @sql{@keys} ) ).'):' );
+			} # end if
+		} else {
+			my @keys = keys %sql;
+			my $command = "UPDATE $table SET " . join(',', map { $_ . ' = ?' } @keys ) . ' WHERE ' . join(' AND ', map { $_ . ' = ?' } @$fields{@identified_by} );
+			if ( ! ( $_ = $local_dbh->prepare($command) and $_->execute( @sql{@keys,@$fields{@identified_by}} ) ) ) {
+				my $error = $local_dbh->errstr;
+				$command =~ s/\?/\%s/g;
+				$log->error('SQL failed: ('.sprintf($command, , map { defined $_ ? $_ : 'undef' } ( @sql{@keys, @$fields{@identified_by}}) ).'):' . $local_dbh->errstr);
+				$local_dbh->rollback();
+				sql::end_transaction( $local_dbh, $ac );
+				return $error;
+			} # end if
+			if ( $debug or DEBUG_ALL ) {
+				$command =~ s/\?/\%s/g;
+				$log->debug('SQL DEBUG: ('.sprintf($command, map { defined $_ ? $_ : 'undef' } ( @sql{@keys,@$fields{@identified_by}} ) ).'):' );
+			} # end if
+		} # end if
+	} else { # not identified_by
+		@identified_by = ('id') if ! @identified_by;
+		my $need_serial = ! ( @identified_by == map { $$self{$_} ? $_ : () } @identified_by );
+
+		if ( $force_insert or $need_serial ) {
+			
+			if ( $need_serial ) {
+				if ( $serial ) {
+					@$self{@identified_by} = @sql{@$fields{@identified_by}} = $local_dbh->selectrow_array( q{SELECT nextval('} . $serial . q{')} );
+					if ( $local_dbh->errstr() )  {
+						$log->error("Error getting next id. " . $local_dbh->errstr() );
+						$log->error("SQL statement execution SELECT nextval('$serial') returned ".join(',',@$self{@identified_by}));
+					} elsif ( $debug or DEBUG_ALL ) {
+						$log->debug("SQL statement execution SELECT nextval('$serial') returned ".join(',',@$self{@identified_by}));
+					} # end if
+				} # end if
+			} # end if
+			my @keys = keys %sql;
+			my $command = "INSERT INTO $table (" . join(',', @keys ) . ') VALUES (' . join(',', map { '?' } @sql{@keys} ) . ')';
+			if ( ! ( $_ = $local_dbh->prepare($command) and $_->execute( @sql{@keys} ) ) ) {
+				$command =~ s/\?/\%s/g;
+				my $error = $local_dbh->errstr;
+				$log->error('SQL failed: ('.sprintf($command, map { defined $_ ? $_ : 'undef' } ( @sql{@keys}) ).'):' . $error);
+				$local_dbh->rollback();
+				sql::end_transaction( $local_dbh, $ac );
+				return $error;
+			} # end if
+			if ( $debug or DEBUG_ALL ) {
+				$command =~ s/\?/\%s/g;
+				$log->debug('SQL DEBUG: ('.sprintf($command, map { defined $_ ? $_ : 'undef' } ( @sql{@keys} ) ).'):' );
+			} # end if
+		} else {
+			delete $sql{created_on};
+			my @keys = keys %sql;
+			@keys = sets::exclude( [ @$fields{@identified_by} ], \@keys );
+			my $command = "UPDATE $table SET " . join(',', map { $_ . ' = ?' } @keys ) . ' WHERE ' . join(' AND ', map { $$fields{$_} .'= ?' } @identified_by );
+			if ( ! ( $_ = $local_dbh->prepare($command) and $_->execute( @sql{@keys}, @sql{@$fields{@identified_by}} ) ) ) {
+				my $error = $local_dbh->errstr;
+				$command =~ s/\?/\%s/g;
+				$log->error('SQL failed: ('.sprintf($command, map { defined $_ ? $_ : 'undef' } ( @sql{@keys}, @sql{@$fields{@identified_by}} ) ).'):' . $error) if $log;
+				$local_dbh->rollback();
+				sql::end_transaction( $local_dbh, $ac );
+				return $error;
+			} # end if
+			if ( $debug or DEBUG_ALL ) {
+				$command =~ s/\?/\%s/g;
+				$log->debug('SQL DEBUG: ('.sprintf($command, map { defined $_ ? ( ref $_ eq 'ARRAY' ? join(',',@{$_}) : $_ ) : 'undef' } ( @sql{@keys}, @$self{@identified_by} ) ).'):' );
+			} # end if
+		} # end if
+	} # end if
+	sql::end_transaction( $local_dbh, $ac );
+	$self->load();
+	#if ( $$fields{id} ) {
+		#if ( ! $ZoneMinder::Object::cache{$type}{$$self{id}} ) {
+			#$ZoneMinder::Object::cache{$type}{$$self{id}} = $self;
+		#} # end if
+	#delete $ZoneMinder::Object::cache{$config{db_name}}{$type}{$$self{id}};
+	#} # end if
+#$log->debug("after delete");
+	#eval 'if ( %'.$type.'::find_cache ) { %'.$type.'::find_cache = (); }';
+#$log->debug("after clear cache");
+	return '';
+} # end sub save
+
+sub set {
+	my ( $self, $params ) = @_;
+	my @set_fields = ();
+
+	my $type = ref $self;
+	my %fields = eval ('%'.$type.'::fields');
+	if ( ! %fields ) {
+		$log->warn('ZoneMinder::Object::set called on an object with no fields');
+	} # end if
+	my %defaults = eval('%'.$type.'::defaults');
+	if ( ref $params ne 'HASH' ) {
+		my ( $caller, undef, $line ) = caller;
+		$openprint::log->error("$type -> set called with non-hash params from $caller $line");
+	}
+
+	foreach my $field ( keys %fields ) {
+$log->debug("field: $field, param: ".$$params{$field}) if $debug;
+		if ( exists $$params{$field} ) {
+$openprint::log->debug("field: $field, $$self{$field} =? param: ".$$params{$field}) if $debug;
+			if ( ( ! defined $$self{$field} ) or ($$self{$field} ne $params->{$field}) ) {
+# Only make changes to fields that have changed
+				if ( defined $fields{$field} ) {
+					$$self{$field} = $$params{$field} if defined $fields{$field};
+					push @set_fields, $fields{$field}, $$params{$field};	#mark for sql updating
+				} # end if
+$openprint::log->debug("Running $field with $$params{$field}") if $debug;
+				if ( my $func = $self->can( $field ) ) {
+					$func->( $self, $$params{$field} );
+				} # end if
+			} # end if
+		} # end if
+
+		if ( defined $fields{$field} ) {
+			if ( $$self{$field} ) {
+				$$self{$field} = transform( $type, $field, $$self{$field} );
+			} # end if $$self{field}
+		}
+	} # end foreach field
+
+	foreach my $field ( keys %defaults ) {
+
+		if ( ( ! exists $$self{$field} ) or (!defined $$self{$field}) or ( $$self{$field} eq '' ) ) {
+			$log->debug("Setting default ($field) ($$self{$field}) ($defaults{$field}) ") if $debug;
+			if ( defined $defaults{$field} ) {
+				$log->debug("Default $field is defined: $defaults{$field}") if $debug;
+				if ( $defaults{$field} eq 'NOW()' ) {
+					$$self{$field} = 'NOW()';
+				} else {
+					$$self{$field} = eval($defaults{$field});
+					$log->error( "Eval error of object default $field default ($defaults{$field}) Reason: " . $@ ) if $@;
+				} # end if
+			} else {
+				$$self{$field} = $defaults{$field};
+			} # end if
+#$$self{$field} = ( defined $defaults{$field} ) ? eval($defaults{$field}) : $defaults{$field};
+			$log->debug("Setting default for ($field) using ($defaults{$field}) to ($$self{$field}) ") if $debug;
+		} # end if
+	} # end foreach default
+	return @set_fields;
+} # end sub set
+
+sub transform {
+	my $type = ref $_[0];
+	$type = $_[0] if ! $type;
+	my $fields = eval '\%'.$type.'::fields';
+	my $value = $_[2];
+
+	if ( defined $$fields{$_[1]} ) {
+		my @transforms = eval('@{$'.$type.'::transforms{$_[1]}}');
+		$openprint::log->debug("Transforms for $_[1] before $_[2]: @transforms") if $debug;
+		if ( @transforms ) {
+			foreach my $transform ( @transforms ) {
+				if ( $transform =~ /^s\// or $transform =~ /^tr\// ) {
+					eval '$value =~ ' . $transform;
+				} elsif ( $transform =~ /^<(\d+)/ ) {
+					if ( $value > $1 ) {
+						$value = undef;
+					} # end if
+				} else {
+	$openprint::log->debug("evalling $value ".$transform . " Now value is $value" );
+					eval '$value '.$transform;
+	$openprint::log->error("Eval error $@") if $@;
+				}
+	$openprint::log->debug("After $transform: $value") if $debug;
+			} # end foreach
+		} # end if 
+	} else {
+		$openprint::log->error("Object::transform ($_[1]) not in fields for $type");
+	} # end if
+	return $value;
+
+} # end sub transform
 1;
 __END__