Skip to content

Instantly share code, notes, and snippets.

@kazeburo
Last active August 29, 2015 14:03
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save kazeburo/d9f2e5d9dfe93798aa84 to your computer and use it in GitHub Desktop.
Save kazeburo/d9f2e5d9dfe93798aa84 to your computer and use it in GitHub Desktop.
diff --git a/server/server.go b/server/server.go
index 0067cec..79e9ae0 100644
--- a/server/server.go
+++ b/server/server.go
@@ -62,7 +62,7 @@ func (self *Server) getAllJobs() {
}
func (self *Server) Start(addr string) {
- ln, err := net.Listen("tcp", ":4730")
+ ln, err := net.Listen("tcp", addr)
if err != nil {
log.Fatal(err)
}
diff --git a/storage/sqlite3/sqlite3.go b/storage/sqlite3/sqlite3.go
index dc12811..a566d2f 100644
--- a/storage/sqlite3/sqlite3.go
+++ b/storage/sqlite3/sqlite3.go
@@ -9,6 +9,7 @@ import (
)
const (
+ createTableSQL = "CREATE TABLE IF NOT EXISTS job(Handle varchar(128),Id varchar(128),Priority INT, CreateAt TIMESTAMP,FuncName varchar(128),Data varchar(16384))"
saveJobSQL = "INSERT INTO job(Handle,Id,Priority,CreateAt,FuncName,Data) VALUES(?,?,?,?,?,?)"
getJobsSQL = "SELECT * FROM job" //need to get all jobs
delJobSQL = "DELETE FROM job WHERE Handle=?"
@@ -32,6 +33,12 @@ func (self *SQLite3Storage) Init() error {
return err
}
+ _, create_err := self.db.Exec(createTableSQL)
+ if create_err != nil {
+ log.Error(create_err)
+ return create_err
+ }
+
return self.db.Ping()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment