diff --git a/agent.go b/agent.go
index f86e2792033f1..e5e144b6f3d0b 100644
--- a/agent.go
+++ b/agent.go
@@ -88,6 +88,8 @@ func (a *Agent) LoadOutputs() ([]string, error) {
 			return nil, fmt.Errorf("Undefined but requested output: %s", name)
 		}
 
+	_, err = c.Query(client.Query{
+		Command: fmt.Sprintf("CREATE DATABASE %s", config.Database),
 		output := creator()
 
 		err := a.Config.ApplyOutput(name, output)