PostgreSQL과 하이퍼레저 패브릭 연동 예제 코드

아래는 Node.js를 사용해 PostgreSQL과 하이퍼레저 패브릭(기업용 블록체인)을 연동하는 예제야:

// PostgreSQL과 하이퍼레저 패브릭 연동 예제
const { Client } = require('pg');
const { Gateway, Wallets } = require('fabric-network');
const path = require('path');
const fs = require('fs');
const crypto = require('crypto');

// PostgreSQL 연결 설정
const pgClient = new Client({
  host: 'localhost',
  port: 5432,
  database: 'finance_db',
  user: 'postgres',
  password: 'your_password'
});

// 데이터 해시 생성 함수
function createDataHash(data) {
  return crypto.createHash('sha256').update(JSON.stringify(data)).digest('hex');
}

async function recordTransactionWithBlockchain() {
  try {
    // PostgreSQL 연결
    await pgClient.connect();
    console.log('PostgreSQL에 연결되었습니다');
    
    // 금융 거래 데이터 생성 (예: 송금)
    const transactionData = {
      sender: 'user123',
      receiver: 'user456',
      amount: 1000.00,
      currency: 'USD',
      timestamp: new Date(),
      description: '월급 지급'
    };
    
    // PostgreSQL에 거래 데이터 저장
    const pgResult = await pgClient.query(
      'INSERT INTO financial_transactions(sender, receiver, amount, currency, timestamp, description, data_hash) VALUES($1, $2, $3, $4, $5, $6, $7) RETURNING id',
      [
        transactionData.sender,
        transactionData.receiver,
        transactionData.amount,
        transactionData.currency,
        transactionData.timestamp,
        transactionData.description,
        createDataHash(transactionData)
      ]
    );
    
    const txId = pgResult.rows[0].id;
    console.log(`거래 ID ${txId}가 PostgreSQL에 저장되었습니다`);
    
    // 하이퍼레저 패브릭 연결 설정
    const ccpPath = path.resolve(__dirname, 'connection-profile.json');
    const ccp = JSON.parse(fs.readFileSync(ccpPath, 'utf8'));
    
    const walletPath = path.join(process.cwd(), 'wallet');
    const wallet = await Wallets.newFileSystemWallet(walletPath);
    
    const identity = await wallet.get('appUser');
    if (!identity) {
      console.log('appUser가 wallet에 존재하지 않습니다');
      return;
    }
    
    // 게이트웨이 연결
    const gateway = new Gateway();
    await gateway.connect(ccp, { 
      wallet, 
      identity: 'appUser', 
      discovery: { enabled: true, asLocalhost: true } 
    });
    
    // 채널 및 컨트랙트 접근
    const network = await gateway.getNetwork('mychannel');
    const contract = network.getContract('financial-contract');
    
    // 블록체인에 거래 해시 기록
    const dataHash = createDataHash(transactionData);
    await contract.submitTransaction(
      'recordTransaction', 
      txId.toString(), 
      dataHash, 
      transactionData.sender,
      transactionData.receiver,
      transactionData.amount.toString()
    );
    
    console.log(`거래 ID ${txId}의 해시가 블록체인에 기록되었습니다`);
    
    // 연결 종료
    gateway.disconnect();
    await pgClient.end();
    
  } catch (error) {
    console.error(`오류 발생: ${error}`);
    if (pgClient) {
      await pgClient.end();
    }
  }
}

recordTransactionWithBlockchain();

이 코드는 금융 거래 데이터를 PostgreSQL에 저장하고, 그 데이터의 해시값을 하이퍼레저 패브릭 블록체인에 기록해. 이렇게 하면 PostgreSQL의 빠른 쿼리 성능과 블록체인의 불변성이라는 두 가지 장점을 모두 활용할 수 있어! 🔐