जाओ एप्लीकेशन में Postgresql समानांतर एकीकरण टेस्ट

एकीकरण परीक्षण परीक्षण पिरामिड के स्तरों में से एक है । आमतौर पर उन्हें अधिक समय की आवश्यकता होती है, क्योंकि उनमें हम वास्तविक घटकों के सिमुलेशन के साथ कुछ भी प्रतिस्थापित नहीं करते हैं। ऐसे परीक्षणों के लिए समय कम करने के लिए, हम उन्हें समानांतर में चला सकते हैं। यहां मैं विशेष रूप से Postgresql के लिए ऐसे परीक्षणों के बारे में बात करूंगा।

आदर्श रूप से, प्रत्येक परीक्षण स्वतंत्र होना चाहिए, इसलिए वे एक-दूसरे को प्रभावित नहीं करेंगे। दूसरे शब्दों में, प्रत्येक परीक्षण फ़ंक्शन की अपनी स्थिति होती है। समानांतर परीक्षणों का उपयोग करने के लिए यह एक अच्छा संकेत है। प्रत्येक परीक्षण फ़ंक्शन के लिए अपना व्यक्तिगत डेटा सेट करने के लिए, मैंने एक फ़ंक्शन बनाया, जो एक परीक्षण शुरू करते समय, एक अस्थायी सर्किट बनाता है, इसमें डेटा लोड करता है और परीक्षण पूरा होने के बाद सर्किट को नष्ट कर देता है। बनाए गए प्रत्येक स्कीमा में नाम संघर्ष को रोकने के लिए नाम में एक हैश होता है।

हेल्पर फ़ंक्शन

चलो परीक्षणों में त्रुटियों को प्रदर्शित करने के लिए एक सहायक फ़ंक्शन के साथ शुरू करते हैं। मैंने बेन जॉनसन के सहायक कार्य (बेन जॉनसन) को लिया, जिससे मुझे कोड की कुछ लाइनों को बचाने और मेरी गलतियों को अधिक स्पष्ट और विस्तृत बनाने में मदद मिली।

डेटा का परीक्षण करें

डेटाबेस के एकीकरण परीक्षण को चलाने के लिए, परीक्षण डेटा प्रदान किया जाना चाहिए। गो परीक्षण उपकरण में फ़ाइलों से परीक्षण डेटा लोड करने के लिए अच्छा समर्थन है। सबसे पहले, "टेस्टडेटा" नामक स्काइप फ़ोल्डर का निर्माण करें। दूसरे, जब आप "गो टेस्ट" चलाते हैं, तो यह मौजूदा फ़ोल्डर को पैकेज फ़ोल्डर में बदल देता है। यह आपको परीक्षण डेटा सेट को लोड करने के लिए टेस्टडेटा फ़ोल्डर के सापेक्ष पथ का उपयोग करने की अनुमति देता है।

परीक्षण के लिए डेटाबेस कनेक्शन बनाना

package database import ( "math/rand" "strconv" "testing" "time" _ "github.com/lib/pq" "database/sql" ) const ( dbPort = 5439 dbUser = "postgres" dbPassword = "postgres" dbName = "test" ) func CreateTestDatabase(t *testing.T) (*sql.DB, string, func()) { connectionString := fmt.Sprintf("port=%d user=%s password=%s dbname=%s sslmode=disable", dbPort, dbUser, dbPassword, dbName) db, dbErr := sql.Open("postgres", connectionString) if dbErr != nil { t.Fatalf("Fail to create database. %s", dbErr.Error()) } rand.Seed(time.Now().UnixNano()) schemaName := "test" + strconv.FormatInt(rand.Int63(), 10) _, err := db.Exec("CREATE SCHEMA " + schemaName) if err != nil { t.Fatalf("Fail to create schema. %s", err.Error()) } return db, schemaName, func() { _, err := db.Exec("DROP SCHEMA " + schemaName + " CASCADE") if err != nil { t.Fatalf("Fail to drop database. %s", err.Error()) } } } 

परीक्षण डेटाबेस से कनेक्शन बनाने और परीक्षणों के लिए एक नया डेटा स्कीमा बनाने के लिए "CreateTestDatabase" को कॉल करना। यह फ़ंक्शन डेटाबेस कनेक्शन, बनाए गए स्कीमा का नाम और इस स्कीमा को हटाने के लिए पर्ज फ़ंक्शन लौटाता है। परीक्षण के लिए, कॉल करने वाले को एक त्रुटि वापस करने की तुलना में परीक्षण को विफल करना बेहतर होता है। (नोट: क्लीनअप फ़ंक्शन की वापसी मिशेल हाशिमोटो की एडवांस्ड टेस्टिंग ऑन गो टॉक पर आधारित है)।

Download टेस्ट डेटासैट

मैंने ".sql" फ़ाइलों का उपयोग किया। एक (1) sql में एक (1) तालिका के लिए डेटा होता है। इसमें एक तालिका बनाना और इसे डेटा के साथ आबाद करना शामिल है। सभी sql फ़ाइलों को "testdata" फ़ोल्डर में संग्रहीत किया जाता है। यहाँ एक उदाहरण sql फ़ाइल है।

 CREATE TABLE book ( title character varying(50), author character varying(50) ); INSERT INTO book VALUES ('First Book','First Author'), ('Second Book','Second Author') ; 

और यहाँ जटिल हिस्सा है। क्योंकि प्रत्येक फ़ंक्शन अपने स्वयं के अनूठे डेटा योजना में चलता है, हम इन sql फ़ाइलों में एक क्वेरी को केवल निष्पादित (लिख) नहीं सकते हैं। तालिका बनाने या वांछित अस्थायी स्कीमा में डेटा सम्मिलित करने के लिए हमें तालिका नामों से पहले स्कीमा को निर्दिष्ट करना होगा। उदाहरण के लिए, क्रिएट टेबल बुक ... क्रिएट टेबल uniqueschema.book ... और INSERT INTO बुक ... INSERT INTO uniqueschema.book में बदलने की जरूरत है ... लिखा जाना चाहिए। मैंने निष्पादन से पहले प्रश्नों को संशोधित करने के लिए नियमित अभिव्यक्ति का उपयोग किया। यहाँ परीक्षण डेटा डाउनलोड कोड है:

 package datalayer import ( "bufio" "fmt" "io" "os" "regexp" "testing" "database/sql" "github.com/Hendra-Huang/databaseintegrationtest/testingutil" //     (   ,  79) ) //        var schemaPrefixRegexps = [...]*regexp.Regexp{ regexp.MustCompile(`(?i)(^CREATE SEQUENCE\s)(["\w]+)(.*)`), regexp.MustCompile(`(?i)(^CREATE TABLE\s)(["\w]+)(\s.+)`), regexp.MustCompile(`(?i)(^ALTER TABLE\s)(["\w]+)(\s.+)`), regexp.MustCompile(`(?i)(^UPDATE\s)(["\w]+)(\s.+)`), regexp.MustCompile(`(?i)(^INSERT INTO\s)(["\w]+)(\s.+)`), regexp.MustCompile(`(?i)(^DELETE FROM\s)(["\w]+)(.*)`), regexp.MustCompile(`(?i)(.+\sFROM\s)(["\w]+)(.*)`), regexp.MustCompile(`(?i)(\sJOIN\s)(["\w]+)(.*)`), } //      func addSchemaPrefix(schemaName, query string) string { prefixedQuery := query for _, re := range schemaPrefixRegexps { prefixedQuery = re.ReplaceAllString(prefixedQuery, fmt.Sprintf("${1}%s.${2}${3}", schemaName)) } return prefixedQuery } func loadTestData(t *testing.T, db *sql.DB, schemaName string, testDataNames ...string) { for _, testDataName := range testDataNames { file, err := os.Open(fmt.Sprintf("./testdata/%s.sql", testDataName)) testingutil.Ok(t, err) reader := bufio.NewReader(file) var query string for { line, err := reader.ReadString('\n') if err == io.EOF { break } testingutil.Ok(t, err) line = line[:len(line)-1] if line == "" { query = addSchemaPrefix(schemaName, query) _, err := db.Exec(query) testingutil.Ok(t, err) query = "" } query += line } file.Close() } } 

परीक्षण निर्माण

प्रत्येक परीक्षण शुरू करने से पहले, योजना के लिए एक अद्वितीय नाम के साथ एक परीक्षण डेटाबेस बनाया जाएगा और इस योजना को हटाने के लिए क्लीनअप फ़ंक्शन के निष्पादन में देरी होगी। परीक्षण में अनुरोध में स्कीमा नाम डाला जाएगा। इस कार्यान्वयन में सबसे महत्वपूर्ण बात यह है कि डेटाबेस से कनेक्शन को वास्तविक डेटाबेस से कनेक्शन को परीक्षण डेटाबेस से कनेक्शन में बदलने के लिए अनुकूलन योग्य होना चाहिए। परीक्षण परिवेश को समानांतर में इस परीक्षण को चलाने की आवश्यकता को इंगित करने के लिए प्रत्येक परीक्षण फ़ंक्शन की शुरुआत में "t.Parallel ()" जोड़ें।
नीचे पूर्ण कोड है:

 //            "integration" (. build flags) // +build integration package datalayer import ( "context" "testing" "github.com/Hendra-Huang/databaseintegrationtest/database" "github.com/Hendra-Huang/databaseintegrationtest/testingutil" ) func TestInsertBook(t *testing.T) { t.Parallel() db, schemaName, cleanup := database.CreateTestDatabase(t) defer cleanup() loadTestData(t, db, schemaName, "book") // will load data which the filename is book title := "New title" author := "New author" // those 2 lines code below are not a good practice // but it is intentional to keep the focus only on integration test part // the important part is database connection has to be configurable insertBookQuery = addSchemaPrefix(schemaName, insertBookQuery) // override the query and add schema to the query err := InsertBook(context.Background(), db, title, author) // will execute insertBookQuery with the provided connection testingutil.Ok(t, err) } func TestGetBooks(t *testing.T) { t.Parallel() db, schemaName, cleanup := database.CreateTestDatabase(t) defer cleanup() loadTestData(t, db, schemaName, "book") getBooksQuery = addSchemaPrefix(schemaName, getBooksQuery) books, err := GetBooks(context.Background(), db) testingutil.Ok(t, err) testingutil.Equals(t, 2, len(books)) } 

नोट: "TestGetBooks," के तहत, मुझे लगता है कि क्वेरी 2 पुस्तकों को वापस कर देगी मैंने "testdata / book.sql" में इतना परीक्षण डेटा सेट दिया है, हालांकि ऊपर एक सम्मिलित परीक्षण है। यदि हम दो परीक्षणों के बीच सर्किट साझा नहीं करते हैं, तो "टेस्टगेटबुक" विफल हो जाएंगे, क्योंकि अब तालिका में 3 पंक्तियाँ, 2 परीक्षण से, 1 ऊपर परीक्षण सम्मिलित से। यह परीक्षणों के लिए अलग सर्किट का लाभ है - उनका डेटा स्वतंत्र है, और इसलिए परीक्षण एक दूसरे से स्वतंत्र हैं।

परियोजना उदाहरण मैं यहाँ github पोस्ट किया। आप इसे स्वयं कॉपी कर सकते हैं, परीक्षण चला सकते हैं और परिणाम देख सकते हैं।

निष्कर्ष

मेरी परियोजना के लिए, यह दृष्टिकोण अनुक्रमिक परीक्षणों की तुलना में परीक्षण के समय को 40-50% तक कम कर देता है। समानांतर में परीक्षण चलाने का एक और फायदा यह है कि हम कुछ त्रुटियों से बच सकते हैं जो तब हो सकती हैं जब कोई एप्लिकेशन कई प्रतिस्पर्धी क्रियाओं को संसाधित करता है।

अच्छी परीक्षा देनी है।

- medium.com/kongkow-it-medan/parallel-database-integration-test-on-go-application-8706b150ee2e से चित्र