दिलचस्प पोस्ट
एक सदस्य अभिव्यक्ति से वस्तु प्राप्त करना? जावा की सीरियलाइज़ेशन कैसे काम करती है और कुछ अन्य दृढ़ता तकनीक के बजाय इसका उपयोग कब किया जाता है? जब पॉड इंस्टॉल चल रहा है तो मुझे `मास्टर` रेपो को कोकाओपॉड 0.32.1 की आवश्यकता है, अपडेट करने का प्रयास करें, लेकिन अभी भी 0.31 में बढ़ावा देने संलयन adapt_struct के साथ नेस्टेड संरचना क्षेत्र में C ++ पुनरावृति सी + + अपवाद सी कोड के माध्यम से सुरक्षित रूप से प्रचार करेंगे? TraceRoute और Ping सी # में जीजीप्लोट 2 में सरल जनसंख्या पिरामिड बच्चे एनजी-दोहर से माता-पिता एनजी-दोहराने का सूचकांक एक्सेस करें एसवीएन – एक शाखा को दूसरे में मिलाएं? डेटा फ्रेम में कई स्तंभों के कारक के लिए संख्यात्मक से वर्ग को बदलें console.writeline और System.out.println यूआईएलएबल पर आईफोन कट कॉपी पेस्ट मेनू दिखाएं विशिष्ट कॉलम प्राप्त करने के लिए हाइबरनेट मापदंड क्वेरी LinearLayoutManager में आइटम्स को ओवरलैप कैसे करें – रीसाइक्लर दृश्य (स्टैकिंग कार्ड की तरह) प्रस्तुत कार्यक्रम घटनाबद्ध रूप से प्रस्तुत किए गए यदि आग्रह नहीं करता है

JavaFX – SQL क्वेरी के लिए पृष्ठभूमि थ्रेड

मैं सोच रहा हूं कि कोई मुझे जावाएफएक्स में एक पृष्ठभूमि धागा बनाने के बारे में एक परेशानी समस्या के साथ मदद कर सकता है! मेरे पास वर्तमान में कई एसक्यूएल प्रश्न हैं जो यूआई में डेटा जोड़ते हैं जो वर्तमान में जावा एफएक्स एप्लीकेशन थ्रेड (नीचे दिए गए उदाहरण देखें) पर चलते हैं। हालांकि, जब इन सभी प्रश्नों को निष्पादित किया जाता है, तो यह यूज़ को फ्रीज़ करता है क्योंकि यह पृष्ठभूमि थ्रेड पर नहीं चल रहा है। मैंने विभिन्न उदाहरणों पर ध्यान दिया है जो कार्य का उपयोग करते हैं और उन्हें समझते हैं लेकिन मैं डेटाबेस क्वेरी करते समय उन्हें काम करने के लिए नहीं मिल सकता, जिनमें से कुछ को चलाने के लिए कुछ सेकंड लगते हैं।

यहां एक तरीका है जो एक क्वेरी निष्पादित करता है:

public void getTopOrders() { customerOrders.clear(); try { Connection con = DriverManager.getConnection(connectionUrl); //Get all records from table String SQL = "EXEC dbo.Get_Top_5_Customers_week"; ResultSet rs; try (Statement stmt = con.createStatement();) { rs = stmt.executeQuery(SQL); while (rs.next()) { double orderValue = Double.parseDouble(rs.getString(3)); customerOrders.add(new CustomerOrders(rs.getString(1), rs.getString(2), "£" + formatter.format(orderValue), rs.getString(4).substring(6, 8) + "/" + rs.getString(4).substring(4, 6) + "/" + rs.getString(4).substring(0, 4))); } } } catch (SQLException | NumberFormatException e) { } } 

प्रत्येक संसाधित रिकॉर्ड को एक ObservableList में जोड़ा जाता है जो कि एक TableView, या ग्राफ़ से जोड़ा जाता है या बस लेबल पर पाठ सेट करता है (क्वेरी पर निर्भर करता है)। मैं एक पृष्ठभूमि थ्रेड पर क्वेरी को कैसे निष्पादित कर सकता हूं और अब भी इंटरफ़ेस का उपयोग करने के लिए नि: शुल्क छोड़ देता है और क्वेरी से अपडेट किया जा सकता है

अग्रिम में धन्यवाद

Solutions Collecting From Web of "JavaFX – SQL क्वेरी के लिए पृष्ठभूमि थ्रेड"

जावा एफएक्स आवेदन थ्रेड के समवर्ती क्रियान्वित धागा पर डेटाबेस का उपयोग करने के लिए मैंने एक कार्य (अलेक्जेंडर किरोव की टिप्पणी में सुझाव दिया गया) का उपयोग करने के लिए एक नमूना समाधान बनाया है।

नमूना समाधान के प्रासंगिक हिस्से नीचे दिए गए हैं:

 // fetches a collection of names from a database. class FetchNamesTask extends DBTask<ObservableList<String>> { @Override protected ObservableList<String> call() throws Exception { // artificially pause for a while to simulate a long // running database connection. Thread.sleep(1000); try (Connection con = getConnection()) { return fetchNames(con); } } private ObservableList<String> fetchNames(Connection con) throws SQLException { logger.info("Fetching names from database"); ObservableList<String> names = FXCollections.observableArrayList(); Statement st = con.createStatement(); ResultSet rs = st.executeQuery("select name from employee"); while (rs.next()) { names.add(rs.getString("name")); } logger.info("Found " + names.size() + " names"); return names; } } // loads a collection of names fetched from a database into a listview. // displays a progress indicator and disables the trigge button for // the operation while the data is being fetched. private void fetchNamesFromDatabaseToListView( final Button triggerButton, final ProgressIndicator databaseActivityIndicator, final ListView listView) { final FetchNamesTask fetchNamesTask = new FetchNamesTask(); triggerButton.setDisable(true); databaseActivityIndicator.setVisible(true); databaseActivityIndicator.progressProperty().bind(fetchNamesTask.progressProperty()); fetchNamesTask.setOnSucceeded(new EventHandler<WorkerStateEvent>() { @Override public void handle(WorkerStateEvent t) { listView.setItems(fetchNamesTask.getValue()); } }); fetchNamesTask.runningProperty().addListener(new ChangeListener<Boolean>() { @Override public void changed(ObservableValue<? extends Boolean> observable, Boolean wasRunning, Boolean isRunning) { if (!isRunning) { triggerButton.setDisable(false); databaseActivityIndicator.setVisible(false); } }; }); databaseExecutor.submit(fetchNamesTask); } private Connection getConnection() throws ClassNotFoundException, SQLException { logger.info("Getting a database connection"); Class.forName("org.h2.Driver"); return DriverManager.getConnection("jdbc:h2:~/test", "sa", ""); } abstract class DBTask<T> extends Task<T> { DBTask() { setOnFailed(new EventHandler<WorkerStateEvent>() { @Override public void handle(WorkerStateEvent t) { logger.log(Level.SEVERE, null, getException()); } }); } } // executes database operations concurrent to JavaFX operations. private ExecutorService databaseExecutor = Executors.newFixedThreadPool( 1, new DatabaseThreadFactory() ); static class DatabaseThreadFactory implements ThreadFactory { static final AtomicInteger poolNumber = new AtomicInteger(1); @Override public Thread newThread(Runnable runnable) { Thread thread = new Thread(runnable, "Database-Connection-" + poolNumber.getAndIncrement() + "-thread"); thread.setDaemon(true); return thread; } } 

ध्यान दें कि एक बार जब आप एक साथ काम करना शुरू करते हैं, तो आपकी कोडिंग और आपके यूआई को कार्य के बिना डिफ़ॉल्ट मोड की तुलना में अधिक जटिल हो जाता है, जब सब कुछ एक ही थ्रेडेड होता है। उदाहरण के लिए, मेरे नमूने में मैंने उस बटन को निष्क्रिय कर दिया जो टास्क को आरंभ करता है ताकि आप पृष्ठभूमि में एक ही काम करते हुए कई कार्य कर सकें (इस प्रकार की प्रोसेसिंग वेब विश्व के समान है, जहां आप किसी पोस्ट को रोकने के लिए एक फॉर्म पोस्ट बटन को अक्षम कर सकते हैं प्रपत्र दोहराया जा रहा है) मैंने इस दृश्य के लिए एक एनिमेटेड प्रगति सूचक भी जोड़ा है, जबकि लंबे समय से चल रहे डेटाबेस कार्य निष्पादित कर रहा था ताकि उपयोगकर्ता का संकेत हो कि कुछ चल रहा है।

जब एक लंबे समय से चलने वाले डेटाबेस ऑपरेशन प्रगति पर है, तो यूआई के अनुभव का प्रदर्शन करने वाला नमूना कार्यक्रम आउटपुट (नोट करें कि प्रगति संकेतक आनयन के दौरान एनिमेटिंग है जिसका मतलब है कि UI उत्तरदायी है हालांकि स्क्रीनशॉट यह प्रदर्शित नहीं करता है):

databasefetcher

एक कार्यान्वयन के साथ एक कार्यान्वयन की अतिरिक्त जटिलता और कार्यक्षमता की तुलना करने के लिए जो कि जावाएफएक्स आवेदन धागा पर सब कुछ निष्पादित करता है, आप एक ही नमूना का दूसरा संस्करण देख सकते हैं जो कार्यों का उपयोग नहीं करता । ध्यान दें कि एक खिलौना के साथ मेरे मामले में, स्थानीय डाटाबेस कार्य आधारित अनुप्रयोग की अतिरिक्त जटिलता अनावश्यक है क्योंकि स्थानीय डाटाबेस आपरेशनों को शीघ्रता से कार्यान्वित करता है, लेकिन अगर आप टास्क आधारित की तुलना में लंबे समय से चलने वाले जटिल प्रश्नों का उपयोग करते हुए बड़े दूरस्थ डेटाबेस से कनेक्ट हो रहे थे दृष्टिकोण उतना सार्थक है क्योंकि यह उपयोगकर्ताओं को एक चिकनी UI अनुभव प्रदान करता है।

ज्वेलरी द्वारा प्रदान किए गए समाधान का उपयोग करने के लिए प्रबंधित किया गया यह ध्यान देने योग्य है कि यदि इस पद्धति को कार्यान्वित करने के दौरान सूचियों, तालिकाओं और / या उन सूचियों सूचियों का उपयोग नहीं किया जाता है जहां आपको किसी पाठ फ़ील्ड या लेबल जैसे किसी आइटम को अपडेट करने की आवश्यकता होती है तो प्लेटफ़ॉर्म के अंदर अपडेट कोड को जोड़ दें। नीचे कुछ कोड स्निपेट हैं जो मेरे काम का समाधान दिखाते हैं।

कोड:

 public void getSalesData() { try { Connection con = DriverManager.getConnection(connectionUrl); //Get all records from table String SQL = "EXEC dbo.Order_Information"; try (Statement stmt = con.createStatement(); ResultSet rs = stmt.executeQuery(SQL)) { while (rs.next()) { todayTot = Double.parseDouble(rs.getString(7)); weekTot = Double.parseDouble(rs.getString(8)); monthTot = Double.parseDouble(rs.getString(9)); yearTot = Double.parseDouble(rs.getString(10)); yearTar = Double.parseDouble(rs.getString(11)); monthTar = Double.parseDouble(rs.getString(12)); weekTar = Double.parseDouble(rs.getString(13)); todayTar = Double.parseDouble(rs.getString(14)); deltaValue = Double.parseDouble(rs.getString(17)); yearPer = yearTot / yearTar * 100; monthPer = monthTot / monthTar * 100; weekPer = weekTot / weekTar * 100; todayPer = todayTot / todayTar * 100; //Doesn't update UI unless you add the update code to Platform.runLater... Platform.runLater(new Runnable() { public void run() { todayTotal.setText("£" + formatter.format(todayTot)); weekTotal.setText("£" + formatter.format(weekTot)); monthTotal.setText("£" + formatter.format(monthTot)); yearTotal.setText("£" + formatter.format(yearTot)); yearTarget.setText("£" + formatter.format(yearTar)); monthTarget.setText("£" + formatter.format(monthTar)); weekTarget.setText("£" + formatter.format(weekTar)); todayTarget.setText("£" + formatter.format(todayTar)); yearPercent.setText(percentFormatter.format(yearPer) + "%"); currentDelta.setText("Current Delta (Week Ends): £" + formatter.format(deltaValue)); } }); } } } catch (SQLException | NumberFormatException e) { } } public void databaseThreadTester() { fetchDataFromDB(); } private void fetchDataFromDB() { final testController.FetchNamesTask fetchNamesTask = new testController.FetchNamesTask(); databaseActivityIndicator.setVisible(true); databaseActivityIndicator.progressProperty().bind(fetchNamesTask.progressProperty()); fetchNamesTask.setOnSucceeded(new EventHandler<WorkerStateEvent>() { @Override public void handle(WorkerStateEvent t) { } }); fetchNamesTask.runningProperty().addListener(new ChangeListener<Boolean>() { @Override public void changed(ObservableValue<? extends Boolean> observable, Boolean wasRunning, Boolean isRunning) { if (!isRunning) { databaseActivityIndicator.setVisible(false); } } ; }); databaseExecutor.submit(fetchNamesTask); } abstract class DBTask<T> extends Task { DBTask() { setOnFailed(new EventHandler<WorkerStateEvent>() { @Override public void handle(WorkerStateEvent t) { } }); } } class FetchNamesTask extends testController.DBTask { @Override protected String call() throws Exception { fetchNames(); return null; } private void fetchNames() throws SQLException, InterruptedException { Thread.sleep(5000); getTopOrders(); getSalesData(); } } 

केवल एक चीज जो इस कार्यान्वयन के साथ काम नहीं करती है, वह निम्नलिखित नहीं है, यह सुनिश्चित नहीं है कि यह काम क्यों नहीं करता है, लेकिन यह ग्राफ को नहीं खींचता है

 public void addCricketGraphData() { yearChart.getData().clear(); series.getData().clear(); series2.getData().clear(); try { Connection con = DriverManager.getConnection(connectionUrl); //Get all records from table String SQL = "...omitted..."; try (Statement stmt = con.createStatement(); ResultSet rs = stmt.executeQuery(SQL)) { while (rs.next()) { Platform.runLater(new Runnable() { @Override public void run() { try { series.getData().add(new XYChart.Data<String, Number>(rs.getString(1), Double.parseDouble(rs.getString(7)))); series2.getData().add(new XYChart.Data<String, Number>(rs.getString(1), Double.parseDouble(rs.getString(8)))); } catch (SQLException ex) { Logger.getLogger(testController.class.getName()).log(Level.SEVERE, null, ex); } } }); } } } catch (SQLException | NumberFormatException e) { } yearChart = createChart(); } protected LineChart<String, Number> createChart() { final CategoryAxis xAxis = new CategoryAxis(); final NumberAxis yAxis = new NumberAxis(); // setup chart series.setName("Target"); series2.setName("Actual"); xAxis.setLabel("Period"); yAxis.setLabel("£"); //Add custom node for each point of data on the line chart. for (int i = 0; i < series2.getData().size(); i++) { nodeCounter = i; final int value = series.getData().get(nodeCounter).getYValue().intValue(); final int value2 = series2.getData().get(nodeCounter).getYValue().intValue(); int result = value2 - value; Node node = new HoveredThresholdNode(0, result); node.toBack(); series2.getData().get(nodeCounter).setNode(node); } yearChart.getData().add(series); yearChart.getData().add(series2); return yearChart; }