做赌博网站推广赚佣金/怎么可以在百度发布信息

通过 INSERT 语句直接写入数据

用户可以通过以下方式执行 INSERT 语句直接向 GaussDB 200 写入数据：

使用 GaussDB 200 提供的客户端工具向 GaussDB 200 写入数据。

通过 JDBC/ODBC 驱动连接数据库执行 INSERT 语句向 GaussDB 200 写入数据。

GaussDB 200 支持完整的数据库事务级别的增删改操作。INSERT 是最简单的一种数据

写入方式，这种方式适合数据写入量不大， 并发度不高的场景。

使用 COPY FROM STDIN 导入数据

关于 COPY FROM STDIN 导入数据

这种方式适合数据写入量不太大， 并发度不太高的场景。

用户可以使用以下方式通过 COPY FROM STDIN 语句直接向 GaussDB 200 写入数据。

通过键盘输入向 GaussDB 200 写入数据。

通过 JDBC 驱动的 CopyManager 接口从文件或者

CopyManager 类简介

CopyManager 是 GaussDB 200 JDBC 驱动中提供的一个 API 接口类，用于批量向 GaussDB

200 集群中导入数据。

CopyManager 的继承关系

CopyManager 类位于 org.postgresql.copy Package 中，继承自 java.lang.Object 类，该类的声

明如下：

public class CopyManager

extends Object

构造方法

public CopyManager(BaseConnection connection)

throws SQLException

常用方法

表 8-7 CopyManager 常用方法

示例 1 ：通过本地文件导入导出数据

在使用 JAVA 语言基于 GaussDB 200 进行二次开发时，可以使用 CopyManager 接口，通过

流方式，将数据库中的数据导出到本地文件或者将本地文件导入数据库中，文件格式

支持 CSV、TEXT 等格式。

样例程序如下，执行时需要加载 GaussDB 200 的 JDBC 驱动。

import java.sql.Connection;

import java.sql.DriverManager;

import java.io.IOException;

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.sql.SQLException;

import org.postgresql.copy.CopyManager;

import org.postgresql.core.BaseConnection;

public class Copy{

public static void main(String[] args)

{

String urls = new String("jdbc:postgresql://localhost:8000/postgres"); //数据库URL

String username = new String("username"); //用户名

String password = new String("passwd"); //密码

String tablename = new String("migration_table"); //定义表信息

String tablename1 = new String("migration_table_1"); //定义表信息

String driver = "org.postgresql.Driver";

Connection conn = null;

try {

Class.forName(driver);

conn = DriverManager.getConnection(urls, username, password);

} catch (ClassNotFoundException e) {

e.printStackTrace(System.out);

} catch (SQLException e) {

e.printStackTrace(System.out);

}

// 将表migration_table中数据导出到本地文件d:/data.txt

try {

copyToFile(conn, "d:/data.txt", "(SELECT * FROM migration_table)");

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

//将d:/data.txt中的数据导入到migration_table_1中。

try {

copyFromFile(conn, "d:/data.txt", tablename1);

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

// 将表migration_table_1中的数据导出到本地文件d:/data1.txt

try {

copyToFile(conn, "d:/data1.txt", tablename1);

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public static void copyFromFile(Connection connection, String filePath, String tableName)

throws SQLException, IOException {

FileInputStream fileInputStream = null;

try {

CopyManager copyManager = new CopyManager((BaseConnection)connection);

fileInputStream = new FileInputStream(filePath);

copyManager.copyIn("COPY " + tableName + " FROM STDIN with (" + "DELIMITER"+"'"+

delimiter + "'" + "ENCODING " + "'" + encoding + "')", fileInputStream);

} finally {

if (fileInputStream != null) {

try {

fileInputStream.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

public static void copyToFile(Connection connection, String filePath, String tableOrQuery)

throws SQLException, IOException {

FileOutputStream fileOutputStream = null;

try {

CopyManager copyManager = new CopyManager((BaseConnection)connection);

fileOutputStream = new FileOutputStream(filePath);

copyManager.copyOut("COPY " + tableOrQuery + " TO STDOUT", fileOutputStream);

} finally {

if (fileOutputStream != null) {

try {

fileOutputStream.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

}

示例 2 ：从 MySQL 向 向 GaussDB 200 进行数据迁移

下面示例演示如何通过 CopyManager 从 MySQL 向 GaussDB 200 进行数据迁移的过程。

import java.io.StringReader;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import org.postgresql.copy.CopyManager;

import org.postgresql.core.BaseConnection;

public class Migration{

public static void main(String[] args) {

String url = new String("jdbc:postgresql://localhost:8000/postgres"); //数据库URL

String user = new String("username"); //GaussDB 200用户名

String pass = new String("passwd"); //GaussDB 200密码

String tablename = new String("migration_table_1"); //定义表信息

String delimiter = new String("|"); //定义分隔符

String encoding = new String("UTF8"); //定义字符集

String driver = "org.postgresql.Driver";

StringBuffer buffer = new StringBuffer(); //定义存放格式化数据的缓存

try {

//获取源数据库查询结果集

ResultSet rs = getDataSet();

//遍历结果集，逐行获取记录

//将每条记录中各字段值，按指定分隔符分割，由换行符结束，拼成一个字符串

//把拼成的字符串，添加到缓存buffer

while (rs.next()) {

buffer.append(rs.getString(1) + delimiter

+ rs.getString(2) + delimiter

+ rs.getString(3) + delimiter

+ rs.getString(4)

+ "\n");

}

rs.close();

try {

//建立目标数据库连接

Class.forName(driver);

Connection conn = DriverManager.getConnection(url, user, pass);

BaseConnection baseConn = (BaseConnection) conn;

baseConn.setAutoCommit(false);

//初始化表信息

String sql = "Copy " + tablename + " from STDIN with (DELIMITER " + "'" +

delimiter + "'" +","+ " ENCODING " + "'" + encoding + "'");

//提交缓存buffer中的数据

CopyManager cp = new CopyManager(baseConn);

StringReader reader = new StringReader(buffer.toString());

cp.copyIn(sql, reader);

baseConn.commit();

reader.close();

baseConn.close();

} catch (ClassNotFoundException e) {

e.printStackTrace(System.out);

} catch (SQLException e) {

e.printStackTrace(System.out);

}

} catch (Exception e) {

e.printStackTrace();

}

}

//********************************

// 从源数据库返回查询结果集

//*********************************

private static ResultSet getDataSet() {

ResultSet rs = null;

try {

Class.forName("com.mysql.jdbc.Driver").newInstance();

Connection conn = DriverManager.getConnection("jdbc:mysql://10.119.179.227:3306/jack?

useSSL=false&allowPublicKeyRetrieval=true", "jack", "Gauss@123");

Statement stmt = conn.createStatement();

rs = stmt.executeQuery("select * from migration_table");

} catch (SQLException e) {

e.printStackTrace();

} catch (Exception e) {

e.printStackTrace();

}

return rs;

}

}