diff --git a/plugin/elastic/connection_producer_test.go b/plugin/elastic/connection_producer_test.go
new file mode 100644
index 0000000..9e32877
--- /dev/null
+++ b/plugin/elastic/connection_producer_test.go
@@ -0,0 +1,63 @@
+package elastic
+
+import (
+	"testing"
+
+	"github.com/ch-robinson/vault-elastic-plugin/testdata"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestInitialize(t *testing.T) {
+	ctx := testdata.NewMockVaultContext()
+
+	urlString := "http://testurl"
+	var empty string
+
+	cp := initializeDatabase(&empty, &urlString)
+
+	err := cp.Initialize(ctx, cp.RawConfig, false)
+
+	assert.Nil(t, err)
+}
+
+func TestInitializeFailOnMissingConnectionUrl(t *testing.T) {
+	ctx := testdata.NewMockVaultContext()
+
+	var empty string
+
+	cp := initializeDatabase(&empty, &empty)
+
+	err := cp.Initialize(ctx, cp.RawConfig, false)
+
+	assert.Equal(t, "connection_url cannot be empty", err.Error())
+}
+
+func TestInitializeFailOnMissingUsername(t *testing.T) {
+	ctx := testdata.NewMockVaultContext()
+
+	urlString := "http://testurl"
+	var empty string
+
+	cp := initializeDatabase(&empty, &urlString)
+
+	cp.Username = empty
+
+	err := cp.Initialize(ctx, cp.RawConfig, false)
+
+	assert.Equal(t, "username cannot be empty", err.Error())
+}
+
+func TestInitializeFailOnMissingPassword(t *testing.T) {
+	ctx := testdata.NewMockVaultContext()
+
+	urlString := "http://testurl"
+	var empty string
+
+	cp := initializeDatabase(&empty, &urlString)
+
+	cp.RawConfig["password"] = empty
+
+	err := cp.Initialize(ctx, cp.RawConfig, false)
+
+	assert.Equal(t, "password cannot be empty", err.Error())
+}