1 files changed, 70 insertions, 0 deletions
diff --git a/src/interfaces/libpgeasy/examples/pgwordcount.c b/src/interfaces/libpgeasy/examples/pgwordcount.c
new file mode 100644
index 00000000000..4715f88f438
--- /dev/null
+++ b/src/interfaces/libpgeasy/examples/pgwordcount.c
@@ -0,0 +1,70 @@
+/*
+ * wordcount.c
+ *
+*/
+
+#include <stdio.h>
+#include "halt.h"
+#include <libpq-fe.h>
+#include "pgeasy.h"
+
+int
+main(int argc, char **argv)
+{
+	char		query[4000];
+	int			row = 0;
+	int			count;
+	char		line[4000];
+
+	if (argc != 2)
+		halt("Usage:  %s database\n", argv[0]);
+
+	connectdb(argv[1], NULL, NULL, NULL, NULL);
+	on_error_continue();
+	doquery("DROP TABLE words");
+	on_error_stop();
+
+	doquery("\
+		CREATE TABLE words( \
+			matches	int4, \
+			word	text ) \
+		");
+	doquery("\
+		CREATE INDEX i_words_1 ON words USING btree ( \
+			word text_ops )\
+		");
+
+	while (1)
+	{
+		if (scanf("%s", line) != 1)
+			break;
+		doquery("BEGIN WORK");
+		sprintf(query, "\
+				DECLARE c_words BINARY CURSOR FOR \
+				SELECT count(*) \
+				FROM words \
+				WHERE word = '%s'", line);
+		doquery(query);
+		doquery("FETCH ALL IN c_words");
+
+		while (fetch(&count) == END_OF_TUPLES)
+			count = 0;
+		doquery("CLOSE c_words");
+		doquery("COMMIT WORK");
+
+		if (count == 0)
+			sprintf(query, "\
+				INSERT INTO words \
+				VALUES (1, '%s')", line);
+		else
+			sprintf(query, "\
+				UPDATE words \
+				SET matches = matches + 1 \
+				WHERE word = '%s'", line);
+		doquery(query);
+		row++;
+	}
+
+	disconnectdb();
+	return 0;
+}