--- rpl/src/instructions_d4.c	2010/01/26 15:22:44	1.1
+++ rpl/src/instructions_d4.c	2010/08/06 15:33:00	1.14
@@ -1,6 +1,6 @@
 /*
 ================================================================================
-  RPL/2 (R) version 4.0.9
+  RPL/2 (R) version 4.0.18
   Copyright (C) 1989-2010 Dr. BERTRAND Joël
 
   This file is part of RPL/2.
@@ -20,7 +20,7 @@
 */
 
 
-#include "rpl.conv.h"
+#include "rpl-conv.h"
 
 
 /*
@@ -38,18 +38,31 @@
 void
 instruction_delete(struct_processus *s_etat_processus)
 {
+	const char					*queue;
+
 	file						*fichier;
 
+	integer8					lecture_i64;
+
 	logical1					erreur;
 	logical1					existence;
 	logical1					ouverture;
 
+	sqlite3_stmt				*ppStmt;
+
+	struct_descripteur_fichier	*descripteur;
+
 	struct_objet				*s_objet_argument;
+	struct_objet				*s_objet_indice;
 
 	struct flock				lock;
 
 	struct stat					requete;
 
+	unsigned char				*commande;
+	unsigned char				*nom;
+	unsigned char				*utf8;
+
 	unsigned long				unite;
 
 	(*s_etat_processus).erreur_execution = d_ex;
@@ -60,15 +73,17 @@ instruction_delete(struct_processus *s_e
 
 		if ((*s_etat_processus).langue == 'F')
 		{
-			printf("(effacement d'un fichier)\n\n");
+			printf("(effacement d'un fichier ou d'un enregistrement)\n\n");
 		}
 		else
 		{
-			printf("(delete a file)\n\n");
+			printf("(delete file or record)\n\n");
 		}
 
-		printf("    1: %s\n", d_CHN);
+		printf("    1: %s\n\n", d_CHN);
 
+		printf("    2: %s, %s\n", d_CHN, d_INT);
+		printf("    1: %s\n", d_FCH);
 		return;
 	}
 	else if ((*s_etat_processus).test_instruction == 'Y')
@@ -79,10 +94,26 @@ instruction_delete(struct_processus *s_e
 
 	if (test_cfsf(s_etat_processus, 31) == d_vrai)
 	{
-		if (empilement_pile_last(s_etat_processus, 1) == d_erreur)
+		if ((*s_etat_processus).l_base_pile == NULL)
 		{
+			(*s_etat_processus).erreur_execution = d_ex_manque_argument;
 			return;
 		}
+
+		if ((*(*(*s_etat_processus).l_base_pile).donnee).type == FCH)
+		{
+			if (empilement_pile_last(s_etat_processus, 2) == d_erreur)
+			{
+				return;
+			}
+		}
+		else
+		{
+			if (empilement_pile_last(s_etat_processus, 1) == d_erreur)
+			{
+				return;
+			}
+		}
 	}
 
 	if (depilement(s_etat_processus, &((*s_etat_processus).l_base_pile),
@@ -94,10 +125,18 @@ instruction_delete(struct_processus *s_e
 
 	if ((*s_objet_argument).type == CHN)
 	{
-		if (stat((unsigned char *) (*s_objet_argument).objet,
-				&requete) != 0)
+		if ((nom = transliteration(s_etat_processus,
+				(unsigned char *) (*s_objet_argument).objet,
+				d_locale, "UTF-8")) == NULL)
+		{
+			liberation(s_etat_processus, s_objet_argument);
+			return;
+		}
+
+		if (stat(nom, &requete) != 0)
 		{
 			liberation(s_etat_processus, s_objet_argument);
+			free(nom);
 
 			(*s_etat_processus).erreur_execution =
 					d_ex_erreur_acces_fichier;
@@ -106,10 +145,10 @@ instruction_delete(struct_processus *s_e
 
 		if (S_ISREG(requete.st_mode)) // Fichier régulier
 		{
-			if ((fichier = fopen((unsigned char *)
-					(*s_objet_argument).objet, "r+")) == NULL)
+			if ((fichier = fopen(nom, "r+")) == NULL)
 			{
 				liberation(s_etat_processus, s_objet_argument);
+				free(nom);
 
 				(*s_etat_processus).erreur_execution =
 						d_ex_erreur_acces_fichier;
@@ -124,6 +163,8 @@ instruction_delete(struct_processus *s_e
 
 			if (fcntl(fileno(fichier), F_GETLK, &lock) == -1)
 			{
+				free(nom);
+
 				if (fclose(fichier) != 0)
 				{
 					liberation(s_etat_processus, s_objet_argument);
@@ -143,29 +184,30 @@ instruction_delete(struct_processus *s_e
 			if (lock.l_type != F_UNLCK)
 			{
 				liberation(s_etat_processus, s_objet_argument);
+				free(nom);
 
 				(*s_etat_processus).erreur_execution =
 						d_ex_erreur_acces_fichier;
 				return;
 			}
 
-			erreur = caracteristiques_fichier(s_etat_processus,
-					(unsigned char *) (*s_objet_argument).objet,
+			erreur = caracteristiques_fichier(s_etat_processus, nom,
 					&existence, &ouverture, &unite);
 
 			if ((erreur != d_absence_erreur) || (ouverture == d_vrai))
 			{
 				liberation(s_etat_processus, s_objet_argument);
+				free(nom);
 
 				(*s_etat_processus).erreur_execution =
 						d_ex_erreur_acces_fichier;
 				return;
 			}
 
-			if (destruction_fichier((unsigned char *)
-					(*s_objet_argument).objet) == d_erreur)
+			if (destruction_fichier(nom) == d_erreur)
 			{
 				liberation(s_etat_processus, s_objet_argument);
+				free(nom);
 
 				(*s_etat_processus).erreur_execution =
 						d_ex_erreur_acces_fichier;
@@ -174,15 +216,353 @@ instruction_delete(struct_processus *s_e
 		}
 		else // Socket
 		{
-			if (unlink((unsigned char *) (*s_objet_argument).objet) != 0)
+			if (unlink(nom) != 0)
 			{
 				liberation(s_etat_processus, s_objet_argument);
+				free(nom);
 
 				(*s_etat_processus).erreur_execution =
 						d_ex_erreur_acces_fichier;
 				return;
 			}
 		}
+
+		free(nom);
+	}
+	else if ((*s_objet_argument).type == FCH)
+	{
+		if ((descripteur = descripteur_fichier(s_etat_processus,
+				(struct_fichier *) (*s_objet_argument).objet)) == NULL)
+		{
+			return;
+		}
+
+		/*
+		 * Vérification des verrous
+		 */
+
+		lock.l_type = F_RDLCK;
+		lock.l_whence = SEEK_SET;
+		lock.l_start = 0;
+		lock.l_len = 0;
+		lock.l_pid = getpid();
+
+		if (fcntl(fileno((*descripteur).descripteur_c), F_GETLK, &lock)
+				== -1)
+		{
+			liberation(s_etat_processus, s_objet_argument);
+
+			(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+			return;
+		}
+
+		if (lock.l_type != F_UNLCK)
+		{
+			liberation(s_etat_processus, s_objet_argument);
+
+			(*s_etat_processus).erreur_execution =
+					d_ex_fichier_verrouille;
+			return;
+		}
+
+		if ((*((struct_fichier *) (*s_objet_argument).objet))
+				.protection == 'R')
+		{
+			liberation(s_etat_processus, s_objet_argument);
+
+			(*s_etat_processus).erreur_execution = d_ex_erreur_acces_fichier;
+			return;
+		}
+
+		if ((*((struct_fichier *) (*s_objet_argument).objet)).binaire == 'N')
+		{
+			if ((*((struct_fichier *) (*s_objet_argument).objet)).acces
+					== 'S')
+			{
+				liberation(s_etat_processus, s_objet_argument);
+
+				(*s_etat_processus).erreur_execution = d_ex_erreur_type_fichier;
+				return;
+			}
+			else if ((*((struct_fichier *) (*s_objet_argument).objet)).acces
+					== 'D')
+			{
+				BUG(((*descripteur).type == 'C'), uprintf("Bad filtype !\n"));
+
+				if (depilement(s_etat_processus, &((*s_etat_processus)
+						.l_base_pile), &s_objet_indice) == d_erreur)
+				{
+					(*s_etat_processus).erreur_execution = d_ex_manque_argument;
+					return;
+				}
+
+				if ((*s_objet_indice).type != INT)
+				{
+					liberation(s_etat_processus, s_objet_argument);
+					liberation(s_etat_processus, s_objet_indice);
+
+					(*s_etat_processus).erreur_execution =
+							d_ex_erreur_type_argument;
+					return;
+				}
+
+				if (alsprintf(&commande, "select count(*) from data where "
+						"id = %lld", (*((integer8 *) (*s_objet_indice).objet)))
+						< 0)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_allocation_memoire;
+					return;
+				}
+
+				if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
+						commande, strlen(commande), &ppStmt, &queue)
+						!= SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_step(ppStmt) != SQLITE_ROW)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				lecture_i64 = sqlite3_column_int64(ppStmt, 0);
+
+				if (sqlite3_step(ppStmt) != SQLITE_DONE)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_finalize(ppStmt) != SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				free(commande);
+
+				if (lecture_i64 == 0)
+				{
+					liberation(s_etat_processus, s_objet_argument);
+					liberation(s_etat_processus, s_objet_indice);
+
+					(*s_etat_processus).erreur_execution =
+							d_ex_enregistrement_inexistant;
+					return;
+				}
+
+				if (alsprintf(&commande, "delete from data where id = %lld",
+						(*((integer8 *) (*s_objet_indice).objet))) < 0)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_allocation_memoire;
+					return;
+				}
+
+				if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
+						commande, strlen(commande), &ppStmt, &queue)
+						!= SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_step(ppStmt) != SQLITE_DONE)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_finalize(ppStmt) != SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				free(commande);
+				liberation(s_etat_processus, s_objet_indice);
+			}
+			else
+			{
+				BUG(((*descripteur).type == 'C'), uprintf("Bad filtype !\n"));
+
+				if (depilement(s_etat_processus, &((*s_etat_processus)
+						.l_base_pile), &s_objet_indice) == d_erreur)
+				{
+					(*s_etat_processus).erreur_execution = d_ex_manque_argument;
+					return;
+				}
+
+				if ((*s_objet_indice).type != CHN)
+				{
+					liberation(s_etat_processus, s_objet_argument);
+					liberation(s_etat_processus, s_objet_indice);
+
+					(*s_etat_processus).erreur_execution =
+							d_ex_erreur_type_argument;
+					return;
+				}
+
+				// Récupération de l'identifiant de la clef
+
+				if ((utf8 = transliteration(s_etat_processus,
+						(unsigned char *) (*s_objet_indice).objet, d_locale,
+						"UTF-8")) == NULL)
+				{
+					liberation(s_etat_processus, s_objet_argument);
+					liberation(s_etat_processus, s_objet_indice);
+
+					return;
+				}
+
+				if (alsprintf(&commande, "select id from key where key = "
+						"'{ \"%s\" }'", utf8) < 0)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_allocation_memoire;
+					return;
+				}
+
+				free(utf8);
+
+				if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
+						commande, strlen(commande), &ppStmt, &queue)
+						!= SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				switch(sqlite3_step(ppStmt))
+				{
+					case SQLITE_ROW:
+					{
+						// Correspondance
+						break;
+					}
+
+					case SQLITE_DONE:
+					{
+						// Aucune correspondance
+						if (sqlite3_finalize(ppStmt) != SQLITE_OK)
+						{
+							(*s_etat_processus).erreur_systeme =
+									d_es_erreur_fichier;
+							return;
+						}
+
+						free(commande);
+
+						liberation(s_etat_processus, s_objet_argument);
+						liberation(s_etat_processus, s_objet_indice);
+
+						(*s_etat_processus).erreur_execution =
+								d_ex_enregistrement_inexistant;
+						return;
+					}
+
+					default:
+					{
+						(*s_etat_processus).erreur_systeme =
+								d_es_erreur_fichier;
+						return;
+					}
+				}
+
+				if (sqlite3_column_type(ppStmt, 0) != SQLITE_INTEGER)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				lecture_i64 = sqlite3_column_int64(ppStmt, 0);
+
+				if (sqlite3_step(ppStmt) != SQLITE_DONE)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_finalize(ppStmt) != SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_erreur_fichier;
+					return;
+				}
+
+				free(commande);
+
+				if (alsprintf(&commande, "delete from data where key_id = %lld",
+						lecture_i64) < 0)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_allocation_memoire;
+					return;
+				}
+
+				if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
+						commande, strlen(commande), &ppStmt, &queue)
+						!= SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_step(ppStmt) != SQLITE_DONE)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_finalize(ppStmt) != SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_erreur_fichier;
+					return;
+				}
+
+				free(commande);
+
+				if (alsprintf(&commande, "delete from key where id = %lld",
+						lecture_i64) < 0)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_allocation_memoire;
+					return;
+				}
+
+				if (sqlite3_prepare_v2((*descripteur).descripteur_sqlite,
+						commande, strlen(commande), &ppStmt, &queue)
+						!= SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_step(ppStmt) != SQLITE_DONE)
+				{
+					(*s_etat_processus).erreur_systeme = d_es_erreur_fichier;
+					return;
+				}
+
+				if (sqlite3_finalize(ppStmt) != SQLITE_OK)
+				{
+					(*s_etat_processus).erreur_systeme =
+							d_es_erreur_fichier;
+					return;
+				}
+
+				free(commande);
+				liberation(s_etat_processus, s_objet_indice);
+			}
+		}
+		else // Fichiers non formatés
+		{
+		}
 	}
 	else
 	{