1

importfunc/import_user_id_map.go

@@ -23,45 +23,44 @@ func ImportUserIdMap() {
 	ctx := context.Background()
 
 	for i := 1; i < 100; i++ {
-		go func(i int) {
+		fmt.Printf("Importing %dth", i)
-			fmt.Printf("Importing %dth", i)
+		pathurl := fmt.Sprintf("/app/data_prep/file/user_id_map%v.txt", i)
-			pathurl := fmt.Sprintf("/app/data_prep/file/user_id_map%v.txt", i)
+		infile, err := os.Open(pathurl)
-			infile, err := os.Open(pathurl)
+		if err != nil {
-			if err != nil {
+			fmt.Printf("Open File Err : %v", err)
-				fmt.Printf("Open File Err : %v", err)
+			return
-				return
+		}
+		reader := bufio.NewReader(infile)
+		userIdMaps := make([]*dbstruct.UserIdMap, 0)
+		for {
+			str, err := reader.ReadString('\n')
+			if len(str) == 0 {
+				continue
 			}
-			reader := bufio.NewReader(infile)
+			strs := strings.Split(str, ":")
-			userIdMaps := make([]*dbstruct.UserIdMap, 0)
+			seq, _ := strconv.Atoi(strs[0])
-			for {
+			userId, _ := strconv.Atoi(strs[1])
-				str, err := reader.ReadString('\n')
+			userIdMaps = append(userIdMaps, &dbstruct.UserIdMap{
-				if len(str) == 0 {
+				Seq:    int64(seq),
-					continue
+				UserId: int64(userId),
-				}
+			})
-				strs := strings.Split(str, ":")
+			if len(userIdMaps) == 1000 {
-				seq, _ := strconv.Atoi(strs[0])
+				err := mcli.CreateMappedUserIds(ctx, userIdMaps)
-				userId, _ := strconv.Atoi(strs[1])
+				if err != nil {
-				userIdMaps = append(userIdMaps, &dbstruct.UserIdMap{
+					fmt.Printf("CreateMappedUserIds err :%v", err)
-					Seq:    int64(seq),
-					UserId: int64(userId),
-				})
-				if len(userIdMaps) == 1000 {
-					err := mcli.CreateMappedUserIds(ctx, userIdMaps)
-					if err != nil {
-						fmt.Printf("CreateMappedUserIds err :%v", err)
-					}
-				}
-				if err == io.EOF {
-					err := mcli.CreateMappedUserIds(ctx, userIdMaps)
-					if err != nil {
-						fmt.Printf("CreateMappedUserIds err :%v", err)
-					}
-					break
 				}
+				userIdMaps = make([]*dbstruct.UserIdMap, 0)
 			}
-			infile.Close()
+			if err == io.EOF {
-			fmt.Printf("%dth imported", i)
+				err := mcli.CreateMappedUserIds(ctx, userIdMaps)
-		}(i)
+				if err != nil {
+					fmt.Printf("CreateMappedUserIds err :%v", err)
+				}
+				break
+			}
+		}
+		infile.Close()
+		fmt.Printf("%dth imported", i)
 	}
 
 	fmt.Printf("Import into test success")