Sqoop导入命令

**Sqoop 导入命令**

Sqoop 是一个用于将数据从关系型数据库（如 MySQL、Oracle 等）或 HDFS 中导入到 Hadoop 的工具。它提供了一个简单的命令行界面，允许用户轻松地导入数据。

在本文中，我们将讨论 Sqoop 导入命令的基本语法和选项，以及一些实例代码示例。

**Sqoop 导入命令基本语法**

Sqoop 导入命令的基本语法如下：

bashsqoop import [options]

其中，`[options]` 是可选参数列表。

**常用选项**

以下是 Sqoop 导入命令中常用的选项：

* `-D`: 指定 Java 系统属性。
* `--connect`: 指定数据库连接字符串。
* `--username`: 指定数据库用户名。
* `--password-file`: 指定密码文件路径。
* `--table`: 指定要导入的表名。
* `--columns`: 指定要导入的列名列表。
* `--where`: 指定过滤条件。
* `--limit`: 指定导入数据量限制。
* `--split-by`: 指定分区字段。

**实例代码示例**

以下是 Sqoop 导入命令的几个实例：

### 示例1：导入 MySQL 表

bashsqoop import 
 --connect jdbc:mysql://localhost:3306/mydb 
 --username root 
 --password-file /path/to/password/file 
 --table mytable 
 --columns id,name,age

在这个例子中，我们使用 Sqoop 导入一个名为 `mytable` 的 MySQL 表，导入 `id`、`name` 和 `age` 这三个列。

### 示例2：过滤条件

bashsqoop import 
 --connect jdbc:mysql://localhost:3306/mydb 
 --username root 
 --password-file /path/to/password/file 
 --table mytable 
 --columns id,name,age 
 --where "age >18"

在这个例子中，我们使用 Sqoop 导入一个名为 `mytable` 的 MySQL 表，过滤条件是 `age` 大于18。

### 示例3：分区字段

bashsqoop import 
 --connect jdbc:mysql://localhost:3306/mydb 
 --username root 
 --password-file /path/to/password/file 
 --table mytable 
 --columns id,name,age 
 --split-by id

在这个例子中，我们使用 Sqoop 导入一个名为 `mytable` 的 MySQL 表，分区字段是 `id`。

### 示例4：导入 HDFS 文件

bashsqoop import 
 --hdfs-dir /path/to/hdfs/file 
 --columns id,name,age

在这个例子中，我们使用 Sqoop 导入一个名为 `/path/to/hdfs/file` 的 HDFS 文件，导入 `id`、`name` 和 `age` 这三个列。

### 示例5：指定 Java 系统属性

bashsqoop import 
 --connect jdbc:mysql://localhost:3306/mydb 
 -Djava.net.useSystemProxies=true 
 --username root 
 --password-file /path/to/password/file 
 --table mytable 
 --columns id,name,age

在这个例子中，我们使用 Sqoop 导入一个名为 `mytable` 的 MySQL 表，指定 Java 系统属性 `java.net.useSystemProxies=true`。

以上是 Sqoop 导入命令的几个实例。这些示例展示了如何使用 Sqoop 导入数据，从 MySQL 表到 HDFS 文件。