Function TestImportFeedNonJSONNewDoc

db/import_test.go:1104–1135

(t *testing.T)

}

func TestImportFeedNonJSONNewDoc(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyMigrate, base.KeyImport)
	base.SkipImportTestsIfNotEnabled(t)
	bucket := base.GetTestBucket(t)
	defer bucket.Close(base.TestCtx(t))

	db, ctx := setupTestDBWithOptionsAndImport(t, bucket, DatabaseContextOptions{})
	defer db.Close(ctx)

	// make sure no documents are imported
	require.Equal(t, int64(0), db.DbStats.SharedBucketImport().ImportCount.Value())
	require.Equal(t, int64(0), db.DbStats.SharedBucketImport().ImportErrorCount.Value())

	// docs named so they will both be on vBucket 1 in both 64 and 1024 vbuckets
	const (
		doc1 = "bookstand"
		doc2 = "chipchop"
	)

	// logs because a JSON number is not a JSON object
	// 	[DBG] .. col:sg_test_0 <ud>bookstand</ud> not able to be imported. Error: Could not unmarshal _sync out of document body: json: cannot unmarshal number into Go value of type db.documentRoot
	_, err := bucket.GetSingleDataStore().Add(doc1, 0, []byte(`1`))
	require.NoError(t, err)

	_, err = bucket.GetSingleDataStore().Add(doc2, 0, []byte(`{"foo" : "bar"}`))
	require.NoError(t, err)

	base.RequireWaitForStat(t, func() int64 {
		return db.DbStats.SharedBucketImport().ImportCount.Value()
	}, 1)
	require.Equal(t, int64(0), db.DbStats.SharedBucketImport().ImportErrorCount.Value())
}

func TestImportFeedNonJSONExistingDoc(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyCRUD, base.KeyMigrate, base.KeyImport)