Add missing /contrib files to CVS.

1 files changed, 89 insertions, 0 deletions

diff --git a/contrib/pg_dumplo/lo_import.c b/contrib/pg_dumplo/lo_import.c
new file mode 100644
index 0000000000..98d81f19fa
--- /dev/null
+++ b/contrib/pg_dumplo/lo_import.c
@@ -0,0 +1,89 @@
+
+#include <stdio.h>	
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+#include <fcntl.h>
+#include <errno.h>                            
+#include <time.h>
+
+#include <libpq-fe.h>
+#include <libpq/libpq-fs.h>
+
+#include "pg_dumplo.h"
+
+extern int 	errno;        
+
+void 
+pglo_import(LODumpMaster *pgLO)
+{
+	LOlist		loa;
+	long 		new_oid;
+	char		tab[MAX_TABLE_NAME], attr[MAX_ATTR_NAME],
+			path[BUFSIZ], lo_path[BUFSIZ],
+			Qbuff[QUERY_BUFSIZ];
+	
+	while(fgets(Qbuff, QUERY_BUFSIZ, pgLO->index)) {
+		
+		if (*Qbuff == '#')
+			continue;
+
+		if (! pgLO->remove && ! pgLO->quiet)
+			printf(Qbuff);
+		
+		sscanf(Qbuff, "%ld\t%s\t%s\t%s\n", &loa.lo_oid, tab, attr, path); 
+		loa.lo_table = tab;
+		loa.lo_attr  = attr;
+
+		sprintf(lo_path, "%s/%s", pgLO->space, path); 
+
+		/* ----------
+		 * Import LO
+		 * ----------
+		 */
+		if ((new_oid = lo_import(pgLO->conn, lo_path)) <= 0) {
+		
+			fprintf(stderr, "%s: %s\n", progname, PQerrorMessage(pgLO->conn));
+			
+			PQexec(pgLO->conn, "ROLLBACK");
+			fprintf(stderr, "\n%s: ROLLBACK\n", progname);
+			exit(RE_ERROR);
+		}
+
+		if (pgLO->remove) {
+			notice(pgLO, FALSE);
+			if (lo_unlink(pgLO->conn, (Oid) loa.lo_oid) < 0) 
+				fprintf(stderr, "%s: can't remove LO: %ld (%s)\n", 
+					progname, loa.lo_oid, PQerrorMessage(pgLO->conn));
+					
+			else if (!pgLO->quiet)
+				printf("remove old %ld and create new %ld\n", 
+					loa.lo_oid, new_oid);	
+			notice(pgLO, TRUE);	
+		}
+		
+		pgLO->counter++;
+	
+		/* ----------
+		 * UPDATE oid in tab
+		 * ----------
+		 */
+		sprintf(Qbuff, "UPDATE %s SET %s=%ld WHERE %s=%ld", 
+			loa.lo_table, loa.lo_attr, new_oid, loa.lo_attr, loa.lo_oid);
+
+		/*fprintf(stderr, Qbuff);*/
+			
+		pgLO->res = PQexec(pgLO->conn, Qbuff);
+	
+		if (!pgLO->res && PQresultStatus(pgLO->res) != PGRES_COMMAND_OK) {
+		
+        		fprintf(stderr, "%s: %s\n",progname, PQerrorMessage(pgLO->conn));
+                	PQclear(pgLO->res);
+                	PQexec(pgLO->conn, "ROLLBACK");
+			fprintf(stderr, "\n%s: ROLLBACK\n", progname);
+			exit(RE_ERROR);
+        	}	
+	}	
+ }