รหัสนี้คือการเชื่อมต่อฐานข้อมูล Micrososft SQL ด้วยคำสั่ง Callable โดยใช้ Java คำสั่ง Callable, พารามิเตอร์และ URL ไดรเวอร์ SQL กำลังเรียกใช้จากไฟล์คุณสมบัติ เมื่อเชื่อมต่อกับฐานข้อมูลแล้วจะมีการเติมค่าทั้งหมดในคอลัมน์ใดคอลัมน์หนึ่งตามแบบสอบถาม คุณสามารถพิมพ์เอาต์พุตฐานข้อมูล SQL ไปยังไฟล์

เชื่อมต่อ MS SQL กับไฟล์คุณสมบัติและคำสั่ง Callable

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

import java.util.Properties; import java.util.Random; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.sql.DriverManager; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException;

DBConnect ระดับสาธารณะ

String เอกชน dbValue;

ประชาชน String getDbValue () {

ส่งคืน dbValue

}

โมฆะสาธารณะ setDbValue (String dbValue) {

this.dbValue = dbValue;

}

String สาธารณะคงที่ callStoredProc () {

InputStream input = null;

ResultSet rs = null;

PreparedStatement ps = null;

การเชื่อมต่อ = null;

ผลลัพธ์ String = null;

ลอง {

String propPath =“. \ src \ props \ db.properties”; // ไฟล์คุณสมบัติ

input = new FileInputStream (propPath);

คุณสมบัติ prop = คุณสมบัติใหม่ ();

prop.load (input); // โหลดไฟล์คุณสมบัติ

// รับค่าคุณสมบัติ

String dbDriver = (prop.getProperty (“ dbDriver”)); // ไดรเวอร์จาก db.properties

String dbURL = (prop.getProperty (“ dbURL”));

Class.forName (DbDriver);

con = DriverManager.getConnection (dbURL);

// การเรียกกระบวนงานที่เก็บไว้

String stPro = (prop.getProperty (“ SPSql1”));

ps = con.prepareStatement (stPro);

ps.setEscapeProcessing (จริง);

ps.setQueryTimeout (90); // ค่าหมดเวลาใช้งาน

ps.setString (1, prop.getProperty (“ VALUE1”));

ps.setString (2, prop.getProperty (“ VALUE2”));

ps.setString (3, prop.getProperty (“ VALUE3”));

rs = ps.executeQuery ();

rs.next ();

// เลือกค่าสุ่มจากช่วง DB ที่ 1-100

int random = (int) (Math.random () * 100 + 1);

int i = 0;

ในขณะที่ (ฉัน <สุ่ม) {

rs.next ();

i ++;

}

ผล = (rs.getString (“ row_name”)); //prop.getProperty("dbRow”)

prop.getProperty (“dbRow”);

prop.getProperty (“value2”);

} catch (IOException e) {

e.printStackTrace ();

} catch (ClassNotFoundException e) {

e.printStackTrace ();

} catch (SQLException e) {

e.printStackTrace ();

} ในที่สุด {

ลอง {

if (rs! = null)

input.close ();

if (rs! = null)

rs.Close ();

if (ps! = null)

ps.close ();

if (con! = null)

con.close ();

} catch (ข้อยกเว้น e) {

e.printStackTrace ();

}

}

ผลตอบแทน;

}

}

// สิ้นสุดชั้นเรียน

// ไฟล์คุณสมบัติ

/*db.properties * /

DbDriver = com.microsoft.sqlserver.jdbc.SQLServerDriver

DbUrl = JDBC: sqlserver: SERVER_URL; ฐานข้อมูล = db_name; ใช้ USERNAME =; = รหัสผ่านรหัสผ่าน

VALUE1 = AAA

VALUE2 = BBB

VALUE3 = CCC

SPSql1 = {call storeprecdurecall (?, ?, ?)}

dbRow = ROW_NAME

DB_USERNAME = uname

DB_PASSWORD = รหัสผ่าน

ตัวอย่างนี้โดยเฉพาะข้อมูลกำลังวนซ้ำจากตารางและเลือกค่าสุ่มจากผลลัพธ์ ในตัวอย่างนี้เราตั้งค่าเป็น 100 และเอาท์พุทจะเลือกค่าสุ่มระหว่าง 1-100 โดยจากผลลัพธ์ของตาราง