package		database		;
use		strict		;
use		warnings		;
use		DBI		;

our		$con			=		"DBI:mysql:test_db"		;
our		$user			=		"root"		;
our		$passwort		=		"pwd"		;
my		$db		;
		
sub		open_db		(		)		{
		$db		=		DBI		->		connect		(		$con		,		$user		,		$passwort		)		or		die		"DB		connection		not		made:		$DBI::errstr"		unless		$db		;
		return		$db		;
}

sub		close_db		(		)		{
		return		unless		$db		;
		$db		->		disconnect		;
		undef		$db		;
}

sub		insert_tab		{
		my		$table			=		shift		;
		my		$values			=		shift		;
		my		$primary_key		=		shift		;
		#		$table		und		$values		müssen		vorhanden		sein!
		return		0		unless		$table		and		$values;

		#		$values		muss		ein		hash		sein!
		return		0		if		ref		$values		ne		'HASH'		;

		#		INSERT		-----------

		#		Keys		und		Values		separieren
		my		@vals		;
		my		@keys		;
		while(		my		(		$k		,		$v		)				=		each		%$values		)		{
				push		@vals		,		$k		;
				push		@keys		,		$v		;
		}
		my		$insert_keys		=		join		',		'		,		@keys		;

		#		Für		jeden		wert		ein		'?'
		my		$insert_vals		=		join		',		'		,		'?'		x		@keys;

		my		$dbh		=		open_db		;

		my		$sth		=		$dbh		->		prepare		(		qq		!INSERT		INTO		$table		(		$insert_keys		)		VALUES		(		$insert_vals		)		!		)		;
		my		$ok		=		$sth		->		execute		(		@$values		)		;
		$sth		->		finish		;

		#		einfügen		Erfolgreich
		return		1		if		$ok		;

		#		einfügen		war		nicht		erfolgreich		aber		kein		Primärer		Key		wurde		definiert
		return		0		unless		defined		$primary_key		;

		#		UPDATE		---------

		#		ist		der		Primäre		Key		aufgeführt?
		return		0		unless		exists		$values		->		{		$primary_key		}		;

		#		primären		key		entfernen
		my		$primary_val		=		delete		$values		->		{		$primary_key		}		;

		#		Keys		und		Values		separieren
		@vals		=		(		)		;
		@keys		=		(		)		;
		while(		my		(		$k		,		$v		)		=		each		%$values		)		{
				push		@vals		,		$k;
				push		@keys		,		$v;
		}
		my		$update_vals		=		join		',		'		,		map		{		"$_		=		?"		}		@keys;

		$sth		=		$dbh		->		prepare		(		qq		!update		$table		SET		$update_vals		WHERE		$primary_key		=		?!		)		;
		$ok		=		$sth		->		execute		(		@vals		,		$primary_val		)		;
		$sth		->		finish		;

		return		$ok;
}

1		;