Function TestMetaDatabase

integration/metadb_test.go:299–335

(t *testing.T)

}

func TestMetaDatabase(t *testing.T) {
	// set up file system interface
	afs := afero.NewOsFs()

	// load config
	cfg, err := config.ReadFileConfig(afs, ConfigPath)
	require.NoError(t, err)

	cfg.Env.DBConnection = dockerInfo.clickhouseConnection

	// import a dataset
	dbName := "test_metadb"
	results, err := cmd.RunImportCmd(time.Now(), cfg, afs, TestDataPath+"/valid_tsv", dbName+"_tsv", false, true)
	require.NoError(t, err, "import should succeed")
	importID := results.ImportID[0]

	// import a few other datasets for testing multiple metadb entries
	_, err = cmd.RunImportCmd(time.Now(), cfg, afs, TestDataPath+"/valid_json", dbName+"_json", false, true)
	require.NoError(t, err, "import should succeed")
	_, err = cmd.RunImportCmd(time.Now(), cfg, afs, TestDataPath+"/open_conns/open", dbName+"_open", false, true)
	require.NoError(t, err, "import should succeed")

	// connect to metadatabase
	db, err := database.ConnectToDB(context.Background(), "metadatabase", cfg, nil)
	require.NoError(t, err)

	// test metadatabase tables
	t.Run("Imports Table", func(t *testing.T) {
		validateMetaDBImportsTable(t, db, dbName+"_tsv", importID)
	})
	t.Run("Files Table", func(t *testing.T) {
		validateMetaDBFilesTable(t, db, TestDataPath+"/valid_tsv", dbName+"_tsv", importID)
	})
	validateMetaDBHistoricalFirstSeenTable(t)
	validateMetaDBValidMimeTypesTable(t)

}
func validateMetaDBImportsTable(t *testing.T, db *database.DB, dbName string, importID util.FixedString) {
	t.Helper()