JDBC は、SQL ステートメントを実行するために使用される Java API です。Java におけるデータベース接続仕様です。この API は次のもので構成されます。いくつかのインターフェイスとクラス。 Java 開発者が複数のリレーショナル データベースに均一にアクセスできるようにする標準 API を提供します。
本質は、コードを通じて MySQL クライアントを実装し、ネットワークとサーバーを通じてデータと対話することです。どこからともなく現れることはできないため、データベースは実装を容易にする一連の API を提供します
データベースには多くの種類があり、データベースごとに提供される API は異なるため、Javaこの問題を解決するために使用されます 1 つの質問は、Java に付属するデータベース操作 API である JDBC を提供します。この API はすべてのデータベース操作モードをカバーします。
本質的に、Java 自体で JDBC API とデータベースが完成します。 API。
を使用して、DataSource オブジェクトを作成します。このオブジェクトは、データベース サーバーの場所を記述します。
DataSource dataSource = new MysqlDataSource(); //设置数据库所在的地址 ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/lmp?characterEncoding=utf8&useSSL=false"); //设置登录数据库的用户名 ((MysqlDataSource)dataSource).setUser("root"); //设置登录数据库的密码 ((MysqlDataSource)dataSource).setPassword("woshizhu123");
Connection 経由でデータベースに接続します (正常に接続するにはパスワードを入力します)
//import java.sql.Connection; Connection connection = dataSource.getConnection();
SQL ステートメントを分割します (SQL ステートメントを作成します)
String sql = "insert into student values(1,'张三')";
SQL ステートメントをオブジェクトにパックします
PreparedStatement statement = connection.prepareStatement(sql);
SQL ステートメントを実行します (Enter キーを押して SQL ステートメントを実行します)
int ret = statement.executeUpdate();
更新削除挿入を実行しますexecuteUpdate() メソッドを使用します
Execute selectexecuteQuery() メソッドを使用する
executeQuery() メソッドを使用すると、見つかったデータを含む resultSet コレクションが返されます。レコード。next を使用して最初のレコードを指します。record を使用し、次に next を使用して次のレコードを指します。
リソースを解放します
statement.close(); connection.close();
public class TestJDBC { public static void main(String[] args) throws SQLException { Scanner scanner = new Scanner(System.in); DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java102?characterEncoding=utf-8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("woshizhu123"); Connection connection = dataSource.getConnection(); System.out.println("输入id"); int id = scanner.nextInt(); System.out.println("输入名字"); String name = scanner.next(); String sql = "insert into student values(?,?)"; PreparedStatement statement = connection.prepareStatement(sql); statement.setInt(1,id); statement.setString(2,name); int ret = statement.executeUpdate(); if(ret == 1){ System.out.println("插入成功"); }else { System.out.println("插入失败"); } statement.close(); connection.close(); } }
public class TestJDBCDelete { public static void main(String[] args) throws SQLException { DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java102?characterEncoding=utf8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("woshizhu123"); Connection connection = dataSource.getConnection(); Scanner scanner = new Scanner(System.in); System.out.println("请输入要删除的id"); int id = scanner.nextInt(); String sql = "delete from student where id = ?"; PreparedStatement preparedStatement = connection.prepareStatement(sql); preparedStatement.setInt(1,id); int ret = preparedStatement.executeUpdate(); System.out.println(ret); preparedStatement.close(); connection.close(); }
public class TestJDBCUpdate { public static void main(String[] args) throws SQLException { DataSource dataSource = new MysqlDataSource(); ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/java102?characterEncoding=utf8&useSSL=false"); ((MysqlDataSource)dataSource).setUser("root"); ((MysqlDataSource)dataSource).setPassword("woshizhu123"); Connection connection = dataSource.getConnection(); Scanner scanner = new Scanner(System.in); System.out.println("请输入要修改的学生id"); int id = scanner.nextInt(); System.out.println("请输入要修改的学生姓名"); String name = scanner.next(); String sql = "update student set name = ? where id = ?"; PreparedStatement statement = connection.prepareStatement(sql); statement.setString(1,name); statement.setInt(2,id); int ret = statement.executeUpdate(); System.out.println(ret); statement.close(); connection.close(); } }
以上がJDBC プログラミングおよび追加、削除、変更、クエリに MySQL を使用する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。