ergo70

/* -------------------------------------------------------------------------
 *
 * worker_spi.c
 *		Sample background worker code that demonstrates various coding
 *		patterns: establishing a database connection; starting and committing
 *		transactions; using GUC variables, and heeding SIGHUP to reread
 *		the configuration file; reporting to pg_stat_activity; using the
 *		process latch to sleep and exit in case of postmaster death.
 *
 * This code connects to a database, creates a schema and table, and summarizes

ergo70

package org.theplateisbad.consumer;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.List;
import java.util.Timer;

ergo70

CREATE OR REPLACE FUNCTION r_predict1(inp integer)
  RETURNS text AS
$BODY$
library(e1071)
data <- seq(1,10)
classes <- c('b','b','b','b','a','a','a','a','b','b')

mysvm = svm (data, classes, type='C', kernel='radial', gamma=0.1, cost=10)
result <- predict(mysvm, inp)

ergo70

library(e1071)

data <- seq(1,10)
classes <- c('b','b','b','b','a','a','a','a','b','b')

mysvm = svm (data, classes, type='C', kernel='radial', gamma=0.1, cost=10)

pred = predict (mysvm, data)

print(table(pred, classes))

ergo70

x <- predict(mysvm,c(2))

print(as.character(x[1:1]))

[1] "b"

x <- predict(mysvm,c(7))

print(as.character(x[1:1]))

ergo70

library(e1071)

data <- seq(1,10)
classes <- c('b','b','b','b','a','a','a','a','b','b')

mysvm = svm (data, classes, type='C', kernel='radial', gamma=0.1, cost=10)

saveRDS(mysvm, "mysvm.rds")

ergo70

CREATE OR REPLACE FUNCTION r_predict2(inp integer)
  RETURNS text AS
$BODY$
if (pg.state.firstpass)
  {
library(e1071)
data <- seq(1,10)
classes <- c('b','b','b','b','a','a','a','a','b','b')

mysvm = svm (data, classes, type='C', kernel='radial', gamma=0.1, cost=10)

ergo70

CREATE OR REPLACE FUNCTION r_predict3(inp integer)
  RETURNS text AS
$BODY$
if (pg.state.firstpass)
  {
library(e1071)

mysvm <- readRDS("mysvm.rds")

assign("pg.state.firstpass", FALSE, env=.GlobalEnv)

ergo70

CREATE OR REPLACE FUNCTION r_predict4(inp integer)
  RETURNS text AS
$BODY$
result <- predict(mysvm, inp)

return(as.character(result[1:1]))
$BODY$
  LANGUAGE plr IMMUTABLE STRICT
  COST 100;

ergo70

INSERT INTO plr_modules VALUES (0, 'library(e1071)');
  
INSERT INTO plr_modules VALUES (1, 'mysvm <- readRDS("mysvm.RDS")');