KR20050074731A - Device for connecting different kind databases and method thereof - Google Patents

Abstract

The present invention relates to an integrated interworking processing device and method between heterogeneous databases.

In the present invention, the integrated interworking processing apparatus is connected to at least one source server and at least one target server through a network to perform data interworking between the servers. In detail, the metadata received from the source server is received, the received metadata is analyzed to analyze the metadata, and an interworking processing task sequence is established according to the analysis. Next, data to be interlocked is collected and stored from the source server according to the interworking processing task sequence, and the collected and stored interlocked data is transmitted to a target server.

According to the present invention, data can be easily transmitted and received between systems using different databases.

Description

Integrated interworking processing device and method between heterogeneous databases {device for connecting different kind databases and method

The present invention relates to an integrated cooperative processing apparatus and a method thereof, and more particularly, to an apparatus and a method for integrated cooperative processing of different types of databases (aka, heterogeneous databases).

In general, servers are operated by building a separate database, and each server connected to a network operates as an independent function. However, the necessity for data exchange between servers is often generated by operational efficiency or user request for new kind of data, and interworking between servers, that is, systems.

In order to interwork, the systems must be connected on the network and the protocols (protocols) promised to each other must be defined in advance. These commitments include what data will be delivered, in what order, at what time and in what way. Once the interlocking rules are established, interworking is possible by implementing the functions in charge. Eventually, through this interworking, each system sends and receives data, thereby achieving the desired purpose.

Inter-system interworking is usually done one-to-many or many-to-many rather than one-to-one. Therefore, the load on the system is increased due to the continuous interworking process, and the system management and development cost is increased due to the complexity of the interworking process with a plurality of systems.

In addition, when a system interworks with several systems, the contents and methods of each interworking are different. However, although the form and media of interworking are almost similar, in the past, separate development costs have been added to develop individual interworking functions with all systems. In addition, by implementing each interlocking function as a separate function block, as the interlocking points (interlocking systems) increase, the interlocking blocks continue to increase, making overall management difficult and difficult to identify the cause when problems occur during operation. There is a problem.

Therefore, the technical problem to be achieved by the present invention is to solve the conventional problems, and is intended to integrate data interworking between different systems.

Another object of the present invention is to provide an integrated interworking processing apparatus and method for performing data interworking between different systems.

In addition, the technical problem to be achieved by the present invention is to efficiently perform data interworking between many-to-many systems through the integrated interlocking processing device.

In order to achieve the above technical problem, the integrated interworking processing apparatus according to an aspect of the present invention is connected to at least one source server and at least one target server through a network, and performs integrated interworking processing to perform data interworking between the servers. An apparatus, comprising: a metadata management unit for receiving metadata provided from the source server; An interlocking controller configured to analyze the meta data to establish a cooperative processing task sequence between the source server and the target server, and to control the cooperative processing according to the work sequence; A data receiver configured to collect source data to be transmitted from the source server under the control of the interworking controller; A message processor which stores source data collected by the data receiver; And a data transmitter for transmitting the source data stored in the message processor to the target server under the control of the interworking controller.

In addition, the processor may further include an adapter processor for processing and receiving and transmitting data according to a protocol type between the source server and the transmission server and the integrated coordinated processing device.

The integrated interworking processing method according to another aspect of the present invention is connected to at least one source server and at least one target server through a network, and performs an integrated interworking processing method for performing data interworking between the servers. Receiving metadata transmitted from a server, analyzing the received metadata to analyze the metadata, and establishing a linkage processing work order according to the analysis; b) collecting and storing data to be interlocked from the source server according to the interworking processing task sequence; And c) transmitting the collected and stored coordinated data to a target server, wherein the metadata includes information about data to be linked with metadata and information about a target with which the data is to be linked.

Here, the step b) is to check the existence of the source server; Confirming a location where the interworking data, which is an interworking target, is stored in the source server; And collecting the interworking data from the source server when the source server exists and the place exists as a result of the checking.

Also, step b) may include checking whether a target server to which the interworking data is transmitted exists. And confirming whether a location where the interworking data is to be stored in the target server is present.

In addition, step c) may include determining a protocol type of the target server; And processing the interworking data according to the protocol type and transmitting the processed data to the target server.

Hereinafter, exemplary embodiments of the present invention will be described in detail with reference to the accompanying drawings so that those skilled in the art may easily implement the present invention. As those skilled in the art would realize, the described embodiments may be modified in various different ways, all without departing from the spirit or scope of the present invention.

1 illustrates a concept of integrated interworking processing according to an embodiment of the present invention, and FIG. 2 illustrates a specific structure of an integrated interworking processing apparatus according to an embodiment of the present invention.

As shown in FIG. 1, the integrated interworking processing apparatus 10 is connected to a plurality of systems, that is, servers 21 to 2n and 31 to 3m, through a network, and performs data interworking between the servers.

Here, for convenience of explanation, a transmission server that provides data (hereinafter, referred to as "interlocked data") for interworking with servers, that is, a source server (21 to 2n) and a reception server for receiving the interworking data. That is, it classified into target server 31-3m. Each server may include a database in which data is stored, and an interface unit for providing data provided from the database to the integrated interlocking processing apparatus or receiving data provided from the integrated interlocking processing apparatus. It includes a metadata generating unit for generating metadata including information.

As shown in FIG. 2, the integrated interworking processing apparatus 10 according to an exemplary embodiment of the present invention connected to these servers may include a metadata management unit 11, an interworking control unit 12, an interworking path management unit 13, And a data receiver 14 and a data transmitter 15, a message processor 16, and an adapter processor 17.

The metadata management unit 11 performs a function of receiving and managing metadata provided from each server. In particular, the source servers 21 to 2n transfer the meta data to the integrated interworking processing apparatus 10 to perform data interworking, and the meta data is managed by the metadata management unit 11 of the integrated interworking processing apparatus 10. It is received and delivered to the interlocking control unit 12.

In an embodiment of the present invention, the metadata is information including general information necessary for data interworking, and an example of the structure of the metadata is shown in FIG. 3.

As illustrated in FIG. 3, the meta data includes information about data to be linked and information about a target to which the data is linked. Specifically, the metadata includes scheduling information, source server information, target server information, source data information, and target. Data information, interworking status information, and protocol type.

The scheduling information includes a linkage execution cycle, a linkage start date, a linkage end date, and a protocol type. The interlocking execution cycle indicates a setting value for how many seconds or minutes to transfer the data to be transmitted. According to the interworking execution cycle, interworking may be performed once a day by bulk interlocking, or may be processed by real-time interlocking. The interlocking start date and the interlocking end date are information indicating when the start point and when the end time point (date) are assumed to occur continuously.

The source server information and the target server information indicate information about the source server and the target server, respectively. Specifically, the server includes an IP address, a DB name (identifier), a DB account, and a DB account password. Access to the server to be linked is performed based on the source server information and the target server information.

The source data information and the target data information respectively indicate in which locations of the database of the corresponding server the interlocked data is stored. In detail, a source table name of a database of a source server where data to be transmitted is stored, or a target table name of a database of a target server where the data is to be delivered and stored, and each table (source and target) in which the data is stored. Table) column name list.

The interlocking state information is information for controlling the interlocking state, and has state values such as interlocking start, pause, and end. In addition, the protocol type indicates what protocol is used for data transmission and reception with an interworking source server and a target server.

Meanwhile, the interworking control unit 12 controls the data transmitting / receiving units 14 and 15 and the message processing unit 16 based on the meta data including the information as described above, so that the source server 21 to 2n and the target server ( Data interworking is performed between 31 and 3 m). Specifically, the interworking control unit 12 analyzes the metadata to establish the interworking route and the interworking processing plan, and controls the work order and processing history of each part 13 to 17 to be worked on in the overall interworking process.

The interlocking path management unit 13 manages the interlocking path information generated by the interlocking control unit 12. More specifically, by comprehensively managing the path information for each interworking between a plurality of systems, the interlocking control unit 12 may recognize the interlocking path and perform data transmission / reception at the time of the actual individual interworking process based on this information list. Make sure The interlocking path information indicates source and target information of the interlocking data and includes a source server ID, a source table ID, a target server ID, and a target table ID. Here, ID is a unique identification system composed of a series of numbers or letters newly assigned each time one new individual interworking metadata is received. Server ID is assigned to each interworking target server, and there are several DB tables or files necessary for transmitting and receiving interlocking data even in one server.

On the other hand, the data transmission and reception unit 14, 15 performs data transmission and reception with a predetermined server. That is, the data receiving unit 14 performs a function of actively collecting coordinated data from a server to transmit the coordinated data indicated in the meta data, that is, the source servers 21 to 2n. Specifically, the data receiving unit 14 receives the data to be interlocked from the corresponding source servers 21 to 2n based on the information (source server information and source table information) transmitted from the interlocking control unit 12 and sends a message. It transfers to the processing part 16. Such data collection work is performed for all source servers included in the interlocking path information, and may be performed continuously, periodically, or sporadically. The data receiver 14 connects to the corresponding source server and collects interlocking target data whenever a work instruction is transmitted from the interlocking controller 12.

In addition, the data transmitter 15 transmits the collected and processed data to the respective target servers. Specifically, the data transmission unit receives the linkage path information and the information on the adapter type required for the linkage from the linkage control unit 12, and then confirms the presence or absence of the target server based on the information, and then transfers the message from the message processing unit 16. The data is transferred to the adapter corresponding to the protocol type of the adapter processing unit 17 with the target server.

Meanwhile, the message processor 16 stores and manages data that is input from the outside of the integrated coordinated processing apparatus and then transferred through the data receiver 14. That is, the message processing unit 16 stores the input data in the storage unit 161, and at this time, the data is stored in the storage unit 161 according to a first-in first-out method. Therefore, the data transmitted from the N source servers are each multiplexed in the input order and stored in the storage unit 161, and the data stored in the storage unit 161 is also output by the first-in first-out method and provided to the data transmission unit 15. It is delivered to the interworking target server. The storage unit 161 is composed of a reception queue 161a and a transmission queue 161b for data processing in both reception and transmission directions. There is one such queue at each of the sender and the receiver. The time the data stays in the queue is independent of scheduling, and the data is input and output in real time.

On the other hand, the adapter processing unit 17 processes data transmission and reception according to the interworking protocol of the counterpart system corresponding to the interworking method or interworking protocol used by interworking between different heterogeneous database management systems (DBMS) or interworking target server.

In general, if it is not the same DBMS model, it is not possible to send and receive data directly between distributed DBs. Therefore, there must be a medium that can convert data to fit the DBMS structure in the middle. In addition, interworking between multiple servers often requires interworking using an interworking protocol suitable for the implementation environment of the system as well as the DBMS type. In order to solve this problem, the present invention implements each adapter function that enables intermediate processing for the most frequently used protocols, and configures an adapter that performs these functions.

In the embodiment of the present invention, it is assumed that the coordinated server 10, that is, the source servers 21 to 2n, on which the integrated coordinated processing device 10 is transmitting, uses a DBMS of the same type as the integrated coordinated processing device and the same network. The processing unit 17 is not formed on the source server side but only on the target server side. However, the present invention is not limited thereto, and in the case where the source server uses heterogeneous DBMSs and networks, an adapter processor may be additionally formed between the source server side and the data receiver 14. That is, the adapter may be selectively formed and used on the transmitting side and / or the receiving side depending on the situation.

4 shows the structure of the adapter processor 17 having this feature. The adapter processing unit 17 includes a plurality of adapters 171 to 175 capable of processing data in accordance with various protocol schemes. In detail, the web service adapter 171, the client Http client adapter 172, the socket adapter 173, the DB link adapter 174, and the CORBA adapter 175 for each interworking method. ), And the corresponding adapter is operated according to the interworking method (protocol type) of the servers to be interlocked to perform data interworking. Here, each of the adapters 171 to 175 of the adapter processing unit 17 may be selectively included. If a new interworking method is added in addition to the above-described adapters, additional adapters for performing data processing according to the interworking method may be further included. Can be.

Next, the operation of the integrated coordinated processing apparatus according to the embodiment of the present invention will be described based on the structure.

5 is a flowchart illustrating an integrated interworking processing method according to an embodiment of the present invention.

First, as illustrated in FIG. 5, a server that requires an interworking operation with a specific server, that is, source servers 21 to 2n generates meta data and transmits the meta data to the integrated interworking processing apparatus 10. The meta data is received by the meta data management unit 11 of the integrated interworking processing apparatus 10 and then transferred to the interworking control unit 12 (S100).

The interlocking control unit 12 of the integrated interlocking processing apparatus 10 analyzes the metadata and whether connection to the corresponding source server and the target server is possible based on the source server information and the target server information obtained according to the analysis, and each server. Verifies whether the connection to the DBMS can be performed. In other words, check the source server and check the table (store) where the data to be linked is stored. In addition, a target server to receive the linkage target data is checked, and a table to receive the linkage target data is checked (S110 to S150).

If connection to the source server and the target server and connection to the DBMS of each server are possible in accordance with the verification operation, the interlocking control unit 12 generates the interlocking path information and makes a work plan. This interlocking path information is stored in the interlocking path management unit 13 and referenced by the interlocking control unit 12 whenever necessary.

Next, the interlocking control unit 12 recognizes the interlocking time by decoding and determining the interlocking start / end information and the interlocking period information from the scheduling information of the meta data. If it is determined that the interlocking time is reached, the data receiving unit 14 transmits the interlocking server, that is, the source server information and the transmission data information, and instructs the corresponding source server to actively collect the interlocking target data.

The data receiving unit 14 connects to the corresponding source servers 21 to 2n based on the collection work instruction and the information (source server information and transmission data information) transmitted from the interlocking control unit 12 and becomes a linking target from a predetermined table in the database. Collect data. At this time, since the DB identification name, password, etc. which can access the database are included in the source server information, the data receiving unit 14 easily accesses the DB. The data obtained by the data collection operation is transferred to the message processing unit 16 by the data receiving unit 14 and stored in the transmission side queue 161a of the storage unit 161 (S160).

On the other hand, according to the first-in first-out method, the message processing unit 16 outputs data from the transmitting side queue 161a and transfers the data to the data transmitting unit 15. The data transmitter 15 establishes a connection with the target servers 31 to 3m according to the interlocking path information transmitted from the interlocking control unit 12. That is, after confirming the existence of the target server, the connection with the target server is established. Then, data is transmitted to the corresponding adapter of the adapter processing unit 17 according to the protocol information with the target server transmitted from the interworking control unit 12, so that data transmission is performed according to the protocol type (S170 to S190).

For example, when the protocol type of the target server is a socket interworking method, the data transmitter 15 transmits data to the socket adapter 173 of the adapter processor 17, and the data processed according to the socket adapter 173 may be The target server 31 to 3m is transmitted through the network (S200).

The integrated interworking process between the source server and the target server as described above may be performed between one source server and multiple target servers, and multiple source servers and multiple target servers.

Although the preferred embodiments of the present invention have been described in detail above, the scope of the present invention is not limited thereto, and various modifications and improvements of those skilled in the art using the basic concepts of the present invention defined in the following claims are also provided. It belongs to the scope of rights.

According to the exemplary embodiment of the present invention, data transmission and reception between systems using different databases are easily performed through the integrated companion device.

In particular, one system continuously develops functions necessary for interworking with a plurality of systems separately, and also improves a lot of inefficiencies in reworking and recompiling interlocking programs every time by changing interworking standards.

In addition, in the present invention, even if the type of data exchanged in the interworking is added or partially changed, the corresponding system modifies only the metadata without additional development of the function or the modification of the existing function and transfers it to the integrated interlocking processing device. Then, the integrated interworking processing apparatus performs the automatic interlocking process based on the interlocking specification content included in the modified metadata. As a result, continuous further development and modification of interworking functions can be minimized, which can cause a lot of time and development cost reduction.

1 is a conceptual diagram of an integrated interworking process according to an exemplary embodiment of the present invention.

2 is a structural diagram of an integrated interworking processing apparatus according to an embodiment of the present invention.

3 is a structural diagram of metadata according to an embodiment of the present invention.

4 is a structural diagram of an adapter processor shown in FIG. 3.

5 is a flowchart of a method for integrated integration processing according to an embodiment of the present invention.

Claims (14)

An integrated interworking processing apparatus connected to at least one source server and at least one target server through a network to perform data interworking between the servers, A meta data manager which receives meta data provided from the source server; An interlocking controller configured to analyze the meta data to establish a cooperative processing task sequence between the source server and the target server, and to control the cooperative processing according to the work sequence; A data receiver configured to collect source data to be transmitted from the source server under the control of the interworking controller; A message processor which stores source data collected by the data receiver; And A data transmitter for transmitting the source data stored in the message processor to the target server under the control of the interworking controller. Including; And the metadata includes information about data to be linked with the metadata and information about a target to which the data is to be linked. The method of claim 1 The meta data includes scheduling information on an interworking data processing order, source server information for a source server providing the interlocking data, target server information for a target server to receive the interlocking data, and a source for a location where the interlocking data is stored. Integrated interworking processing including at least one of data information, target data information on a location at which the interworking data is to be stored in a target server, interworking state information indicating an interworking state of the source server and the target server, and protocol information for transmitting and receiving data. Device. The method of claim 2 The scheduling information includes a linkage execution period, a linkage start date, a linkage end date, and a protocol type. The interlocking execution cycle includes at least one of an interlocking execution cycle, an interlocking start date, and an interlocking end date, which are setting values for how many seconds or minutes to deliver data to be transmitted. The method of claim 2 The source server information and the target server information may each include at least one of an address of a source server and a target server, an identifier of a database storing interlocking data, an account assigned to the database, and a password for accessing the database. Processing unit. The method of claim 2 The source data information including a source table name of a database of a source server in which the data to be transmitted is stored, and the target data information includes a target table name of a database of a target server to which the data is to be transmitted and stored; Processing unit. The method of claim 2 The interlocking state information is information for controlling the state of the interlocking, and indicates an interlocking start, pause, or end. The method according to claim 1 or 2 The metadata further includes information indicating a protocol type of the source server and a target server to interwork with. The method of claim 7, And an adapter processing unit for processing, receiving, and transmitting data according to a protocol type between the source server, the transmission server, and the integrated coordinated processing device. The method of claim 8 The adapter processor may include at least one of a web service adapter, a Http client adapter, a socket adapter, a DB link adapter, and a CORBA adapter. The method of claim 9 And the data transmitter is provided to a corresponding adapter of the adapter processor according to a protocol type with a target server so that data transmission to the target server is performed according to the protocol. In the integrated interworking processing method is connected to at least one source server and at least one target server through a network to perform data interworking between the servers a) receiving metadata transmitted from the source server, analyzing the received metadata to analyze the metadata, and establishing an interworking processing task sequence according to the analysis; b) collecting and storing data to be interlocked from the source server according to the interworking processing task sequence; And c) transmitting the collected stored interworking data to a target server; Including, The meta data, the meta data, the meta data includes information on data to be interlocked and information on a target to which the data is interlocked. The method of claim 11, Step b) Checking the existence of the source server; Confirming a location where the interworking data, which is an interworking target, is stored in the source server; And Collecting the interworking data from the source server if the source server exists and the place exists as a result of the checking; Integrated interworking processing method comprising a. The method according to claim 11 or 12. Step b) Confirming whether a target server to which the interworking data is to be transmitted exists; And Confirming whether a location where the interworking data is to be stored in the target server is present; Integration interworking processing method further comprising. The method of claim 11, Step c) Determining a protocol type of the target server; And Processing and transmitting the interworking data to the target server according to the protocol type Integrated interworking processing method comprising a.